GremlinPython用aiohttp向DriverRemoteConnection添加连接和请求超时

Question

我正在将gremlinpython包从3.4升级到3.5

作为升级的一部分，龙卷风已经被删除，并且只支持aiohttp。

在此之前，为了创建具有连接和请求超时的DriverRemoteConnection，我使用了以下代码

from tornado import httpclient

req = httpclient.HTTPRequest(
    connection_str,
    connect_timeout=gremlin_connect_timeout_secs, 
    request_timeout=gremlin_request_timeout_secs
)
driver_remote_connection = DriverRemoteConnection(
    req, "g", pool_size=pool_size, max_workers=max_workers
)
g = traversal().withRemote(driver_remote_connection)

现在已经不再支持龙卷风了，在3.5+中什么是等价的呢？

我和AWS海王星的联系。

我已经查看了aiogremlin包和aiohttp库，但是它要求我创建异步客户端，而我不需要连接是异步的。

我可以用以下简单的方法创建DriverRemoteConnection

driver_remote_connection = DriverRemoteConnection(
    self.conn, pool_size=self.pool_size, max_workers=self.max_workers
)

但是，我无法传递连接/请求超时。

Answer 1

通过挖掘gremlinpython和aiohttp的源代码找到答案。

传递给DriverRemoteConnection的kwargs被传递给AiohttpTransport。因此，传递连接和请求超时参数的正确方法如下：

driver_remote_connection = DriverRemoteConnection(
    self.conn,
    pool_size=self.pool_size,
    max_workers=self.max_workers,
    timeout=gremlin_connect_timeout_secs,
    read_timeout=gremlin_request_timeout_secs,
)