0

如何从 AWS Neptune 获取活动连接数?

我收到以下错误

Cannot write to closing transport: ConnectionResetError
Traceback (most recent call last):
  File "/var/task/chalice/app.py", line 1569, in __call__
    return self.handler(event_obj)
  File "/var/task/chalice/app.py", line 1522, in __call__
    return self._original_func(event.to_dict(), event.context)
  File "/var/task/app.py", line 28, in handler
    return query(event, context)
  File "/var/task/app.py", line 45, in query
    is_user_available(event)
  File "/var/task/app.py", line 186, in is_user_available
    user_available = get_g().V(cognito_username).hasNext()
  File "/var/task/gremlin_python/process/traversal.py", line 80, in hasNext
    self.traversal_strategies.apply_strategies(self)
  File "/var/task/gremlin_python/process/traversal.py", line 548, in apply_strategies
    traversal_strategy.apply(traversal)
  File "/var/task/gremlin_python/driver/remote_connection.py", line 63, in apply
    remote_traversal = self.remote_connection.submit(traversal.bytecode)
  File "/var/task/gremlin_python/driver/driver_remote_connection.py", line 59, in submit
    result_set = self._client.submit(bytecode, request_options=self._extract_request_options(bytecode))
  File "/var/task/gremlin_python/driver/client.py", line 123, in submit
    return self.submitAsync(message, bindings=bindings, request_options=request_options).result()
  File "/var/lang/lib/python3.6/concurrent/futures/_base.py", line 432, in result
    return self.__get_result()
  File "/var/lang/lib/python3.6/concurrent/futures/_base.py", line 384, in __get_result
    raise self._exception
  File "/var/task/gremlin_python/driver/connection.py", line 66, in cb
    f.result()
  File "/var/lang/lib/python3.6/concurrent/futures/_base.py", line 425, in result
    return self.__get_result()
  File "/var/lang/lib/python3.6/concurrent/futures/_base.py", line 384, in __get_result
    raise self._exception
  File "/var/lang/lib/python3.6/concurrent/futures/thread.py", line 56, in run
    result = self.fn(*self.args, **self.kwargs)
  File "/var/task/gremlin_python/driver/protocol.py", line 86, in write
    self._transport.write(message)
  File "/var/task/gremlin_python/driver/aiohttp/transport.py", line 86, in write
    self._loop.run_until_complete(async_write())
  File "/var/lang/lib/python3.6/asyncio/base_events.py", line 488, in run_until_complete
    return future.result()
  File "/var/task/gremlin_python/driver/aiohttp/transport.py", line 83, in async_write
    await self._websocket.send_bytes(message)
  File "/var/task/aiohttp/client_ws.py", line 155, in send_bytes
    await self._writer.send(data, binary=True, compress=compress)
  File "/var/task/aiohttp/http_websocket.py", line 685, in send
    await self._send_frame(message, WSMsgType.BINARY, compress)
  File "/var/task/aiohttp/http_websocket.py", line 598, in _send_frame
    raise ConnectionResetError("Cannot write to closing transport")
ConnectionResetError: Cannot write to closing transport
4

0 回答 0