Как получить количество активных подключений из AWS Neptune?
Как получить количество активных подключений из 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