Open
Description
Hey! I don't understand what I'm doing wrong, please help :)
Several insert transactions work ok, but then it fails. I'm using clickhouse-sqlalchemy with asynch driver.
My code:
async with AsyncSessionCompressed() as session:
await session.execute(insert(QueryLog.__table__), [log_entry])
I got error:
Code: 102. Unexpected packet from server clickhouse-click.clickhouse.svc:9000 (expected Pong, got Hello), Traceback (most recent call last):
File "/app/blockchainScrapper/graphql_fix.py", line 142, in execute
await session.execute(insert(QueryLog.__table__), [log_entry])
File "/usr/local/lib/python3.12/site-packages/sqlalchemy/ext/asyncio/session.py", line 313, in execute
result = await greenlet_spawn(
^^^^^^^^^^^^^^^^^^^^^
File "/usr/local/lib/python3.12/site-packages/sqlalchemy/util/_concurrency_py3k.py", line 165, in greenlet_spawn
result = context.throw(*sys.exc_info())
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
File "/usr/local/lib/python3.12/site-packages/sqlalchemy/orm/session.py", line 2229, in execute
return self._execute_internal(
^^^^^^^^^^^^^^^^^^^^^^^
File "/usr/local/lib/python3.12/site-packages/sqlalchemy/orm/session.py", line 2133, in _execute_internal
result = conn.execute(
^^^^^^^^^^^^^
File "/usr/local/lib/python3.12/site-packages/sqlalchemy/engine/base.py", line 1414, in execute
return meth(
^^^^^
File "/usr/local/lib/python3.12/site-packages/sqlalchemy/sql/elements.py", line 489, in _execute_on_connection
return connection._execute_clauseelement(
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
File "/usr/local/lib/python3.12/site-packages/sqlalchemy/engine/base.py", line 1638, in _execute_clauseelement
ret = self._execute_context(
^^^^^^^^^^^^^^^^^^^^^^
File "/usr/local/lib/python3.12/site-packages/sqlalchemy/engine/base.py", line 1842, in _execute_context
return self._exec_single_context(
^^^^^^^^^^^^^^^^^^^^^^^^^^
File "/usr/local/lib/python3.12/site-packages/sqlalchemy/engine/base.py", line 1983, in _exec_single_context
self._handle_dbapi_exception(
File "/usr/local/lib/python3.12/site-packages/sqlalchemy/engine/base.py", line 2328, in _handle_dbapi_exception
raise exc_info[1].with_traceback(exc_info[2])
File "/usr/local/lib/python3.12/site-packages/sqlalchemy/engine/base.py", line 1933, in _exec_single_context
self.dialect.do_executemany(
File "/usr/local/lib/python3.12/site-packages/clickhouse_sqlalchemy/drivers/asynch/base.py", line 39, in do_executemany
cursor.executemany(statement, parameters, context)
File "/usr/local/lib/python3.12/site-packages/clickhouse_sqlalchemy/drivers/asynch/connector.py", line 71, in executemany
return self.await_(self._executemany_async(operation, params, context))
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
File "/usr/local/lib/python3.12/site-packages/sqlalchemy/util/_concurrency_py3k.py", line 102, in await_only
return current.driver.switch(awaitable) # type: ignore[no-any-return]
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
File "/usr/local/lib/python3.12/site-packages/sqlalchemy/util/_concurrency_py3k.py", line 160, in greenlet_spawn
value = await result
^^^^^^^^^^^^
File "/usr/local/lib/python3.12/site-packages/clickhouse_sqlalchemy/drivers/asynch/connector.py", line 75, in _executemany_async
return await self._cursor.executemany(
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
File "/usr/local/lib/python3.12/site-packages/asynch/cursors.py", line 129, in executemany
response = await execute(query, args=args, **execute_kwargs)
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
File "/usr/local/lib/python3.12/site-packages/asynch/proto/connection.py", line 630, in execute
async with ExecuteContext(self, query, settings):
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
File "/usr/local/lib/python3.12/site-packages/asynch/proto/context.py", line 50, in __aenter__
await self._connection.force_connect()
File "/usr/local/lib/python3.12/site-packages/asynch/proto/connection.py", line 753, in force_connect
elif not await self.ping():
^^^^^^^^^^^^^^^^^
File "/usr/local/lib/python3.12/site-packages/asynch/proto/connection.py", line 315, in ping
raise UnexpectedPacketFromServerError(msg)
asynch.errors.UnexpectedPacketFromServerError: Code: 102. Unexpected packet from server clickhouse-click.clickhouse.svc:9000 (expected Pong, got Hello)
Metadata
Metadata
Assignees
Labels
No labels