Соединение Apache Пино

Question

Я новичок в работе с Apache Pinot, и мне бы хотелось, чтобы вы помогли мне понять, как он работает. В настоящее время мы работаем с AWS, и в кластере AWS EKS установлен Apache Pinot. У меня есть прямая ссылка/соединение, и я могу использовать несколько команд, предоставляемых Swagger в API контроллера Pinot. Служба контроллера открыта.

Я хочу работать с библиотекой pinotdb в Python, как сказано в документации , но когда я пробую небольшой код вроде:

      from pinotdb import connect


hosted='MyLinkConnection'
#Port=9000
Port=8098


def lambda_handler(event, context):
    conn = connect(host=hosted, port=Port, scheme='http')
    curs = conn.cursor()
    
    #curs.execute("select * from TestTable;")
    curs.execute("select * from TestTable_OFFLINE;")
    
    for row in curs:
        print(row)
    print('Gone')

Эта ошибка возвращается:

      {
  "errorMessage": "timed out",
  "errorType": "ConnectTimeout",
  "stackTrace": [
    "  File \"/var/task/lambda_function.py\", line 15, in lambda_handler\n    curs.execute(\"select * from TestTable_OFFLINE;\")\n",
    "  File \"/opt/python/pinotdb/db.py\", line 57, in g\n    return f(self, *args, **kwargs)\n",
    "  File \"/opt/python/pinotdb/db.py\", line 490, in execute\n    **kwargs)\n",
    "  File \"/opt/python/httpx/_client.py\", line 1149, in post\n    extensions=extensions,\n",
    "  File \"/opt/python/httpx/_client.py\", line 821, in request\n    return self.send(request, auth=auth, follow_redirects=follow_redirects)\n",
    "  File \"/opt/python/httpx/_client.py\", line 912, in send\n    history=[],\n",
    "  File \"/opt/python/httpx/_client.py\", line 939, in _send_handling_auth\n    history=history,\n",
    "  File \"/opt/python/httpx/_client.py\", line 973, in _send_handling_redirects\n    response = self._send_single_request(request)\n",
    "  File \"/opt/python/httpx/_client.py\", line 1009, in _send_single_request\n    response = transport.handle_request(request)\n",
    "  File \"/opt/python/httpx/_transports/default.py\", line 218, in handle_request\n    resp = self._pool.handle_request(req)\n",
    "  File \"/var/lang/lib/python3.7/contextlib.py\", line 130, in __exit__\n    self.gen.throw(type, value, traceback)\n",
    "  File \"/opt/python/httpx/_transports/default.py\", line 77, in map_httpcore_exceptions\n    raise mapped_exc(message) from exc\n"
  ]
}

Я могу подключиться к консоли, если войду в MyLinkConnection

Но я хочу создать соединение с библиотекой pinotdb или JDBC, всегда в Python, может ли кто-нибудь мне помочь?

Я уже пытаюсь предоставить службам: контроллер (для консоли), брокер, сервер и Zookeper свои собственные порты по мере возвращения документации.