python 与 azure gremlin 的集成不起作用

Question

我正在尝试模仿 GIT 中提到的那样。

我几乎评论了所有内容，只是想运行简单

g.V().count()

我的连接详细信息是正确的，并且与文档相匹配...

我遇到以下错误。

Traceback (most recent call last):
  File "c:\Users\PrasaRak\OneDrive\gremlin_azure_function\connect.py", line 193, in <module>
    count_vertices(client)
  File "c:\Users\PrasaRak\OneDrive\gremlin_azure_function\connect.py", line 116, in count_vertices
    callback = client.submit(_gremlin_count_vertices)
  File "C:\Users\PrasaRak\Miniconda3\envs\learn-gremlin\lib\site-packages\gremlin_python\driver\client.py", line 127, in submit
    return self.submitAsync(message, bindings=bindings, request_options=request_options).result()
  File "C:\Users\PrasaRak\Miniconda3\envs\learn-gremlin\lib\site-packages\gremlin_python\driver\client.py", line 148, in submitAsync
    return conn.write(message)
  File "C:\Users\PrasaRak\Miniconda3\envs\learn-gremlin\lib\site-packages\gremlin_python\driver\connection.py", line 55, in write
    self.connect()
  File "C:\Users\PrasaRak\Miniconda3\envs\learn-gremlin\lib\site-packages\gremlin_python\driver\connection.py", line 45, in connect
    self._transport.connect(self._url, self._headers)
  File "C:\Users\PrasaRak\Miniconda3\envs\learn-gremlin\lib\site-packages\gremlin_python\driver\tornado\transport.py", line 40, in connect
    self._ws = self._loop.run_sync(
  File "C:\Users\PrasaRak\Miniconda3\envs\learn-gremlin\lib\site-packages\tornado\ioloop.py", line 576, in run_sync
    return future_cell[0].result()
  File "C:\Users\PrasaRak\Miniconda3\envs\learn-gremlin\lib\site-packages\tornado\simple_httpclient.py", line 269, in run
    stream = yield self.tcp_client.connect(
  File "C:\Users\PrasaRak\Miniconda3\envs\learn-gremlin\lib\site-packages\tornado\gen.py", line 1133, in run
    value = future.result()
  File "C:\Users\PrasaRak\Miniconda3\envs\learn-gremlin\lib\site-packages\tornado\gen.py", line 1147, in run
    yielded = self.gen.send(value)
  File "C:\Users\PrasaRak\Miniconda3\envs\learn-gremlin\lib\site-packages\tornado\tcpclient.py", line 232, in connect
    af, addr, stream = yield connector.start(connect_timeout=timeout)
  File "C:\Users\PrasaRak\Miniconda3\envs\learn-gremlin\lib\site-packages\tornado\tcpclient.py", line 87, in start
    self.try_connect(iter(self.primary_addrs))
  File "C:\Users\PrasaRak\Miniconda3\envs\learn-gremlin\lib\site-packages\tornado\tcpclient.py", line 104, in try_connect
    stream, future = self.connect(af, addr)
  File "C:\Users\PrasaRak\Miniconda3\envs\learn-gremlin\lib\site-packages\tornado\tcpclient.py", line 276, in _create_stream
    return stream, stream.connect(addr)
  File "C:\Users\PrasaRak\Miniconda3\envs\learn-gremlin\lib\site-packages\tornado\iostream.py", line 1325, in connect
    self._add_io_state(self.io_loop.WRITE)
  File "C:\Users\PrasaRak\Miniconda3\envs\learn-gremlin\lib\site-packages\tornado\iostream.py", line 1157, in _add_io_state
    self.io_loop.add_handler(
  File "C:\Users\PrasaRak\Miniconda3\envs\learn-gremlin\lib\site-packages\tornado\platform\asyncio.py", line 83, in add_handler
    self.asyncio_loop.add_writer(
  File "C:\Users\PrasaRak\Miniconda3\envs\learn-gremlin\lib\asyncio\events.py", line 507, in add_writer
    raise NotImplementedError
NotImplementedError

Answer 1

我想我找到了答案。

问题是 python 3.8 和 Tornado 兼容性，当涉及到 asyncio 时。

更多信息在此link

修复是在 tornado/platform/asyncio.py

中添加以下行

asyncio.set_event_loop_policy(asyncio.WindowsSelectorEventLoopPolicy())  # python-3.8.0a4

python 与 azure gremlin 的集成不起作用

python integration with azure gremlin not working

azure-cosmosdb-gremlinapi