你好,社区。
我正在使用AWS中的EKS集群。
我已经在这个集群的一个节点上安装了Apache pinot。
我已经创建了一个虚拟服务,网关和负载均衡器,它返回了一个链接,我可以在那里检查Apache pinot UI。Egg:http://LoadBalancer.. amazonaws.com
即使我想使用python,并且我使用这个端点的API:http://LoadBalancer.. amazonaws.com它的作品,蛋:
import requests
# Get request to URI
response = requests.get("http://LoadBalancer.<My region>.amazonaws.com/tables")
# Check if request was successfully
if response.status_code == 200:
data = response.json()
print(data['tables'])
else:
print("Error in request:", response.status_code)
这仍然有效,但是当我想使用pinotdb API时,它就不起作用了,它会以那种方式返回超时或错误。
from pinotdb import connect
hosted = 'LoadBalancer.<My region>.amazonaws.com'
connection = connect(host=hosted, port=8099, scheme='http')
cursor = connection.cursor()
# execute a query
query = "select * from testing limit 10"
cursor.execute(query)
在我用kubectl命令配置的虚拟服务中,我链接了我的pinot控制器,在端口9000中向我展示了UI,我在端口8099中创建了另一个pinot broker虚拟服务,但pinotdb API不工作。
有人能帮我解决这个问题吗?或者是不可能做我想做的事?
1条答案
按热度按时间tgabmvqs1#
根据官方文件。
在建立连接时,您必须传递API路径。
connection = connect(host=hosted, port=8099, path='/query/sql', scheme='http')