---------------------------------------------------------------------------
error Traceback (most recent call last)
~/dev/kafka_sink/venv/lib/python3.7/site-packages/clickhouse_driver/columns/base.py in write_items(self, items, buf)
141 try:
--> 142 buf.write(s.pack(*items))
143
error: required argument is not an integer
During handling of the above exception, another exception occurred:
StructPackException Traceback (most recent call last)
~/dev/kafka_sink/venv/lib/python3.7/site-packages/clickhouse_driver/columns/service.py in write_column(context, column_name, column_spec, items, buf, types_check)
90 column.write_state_prefix(buf)
---> 91 column.write_data(items, buf)
92
~/dev/kafka_sink/venv/lib/python3.7/site-packages/clickhouse_driver/columns/base.py in write_data(self, items, buf)
78
---> 79 self._write_data(items, buf)
80
~/dev/kafka_sink/venv/lib/python3.7/site-packages/clickhouse_driver/columns/base.py in _write_data(self, items, buf)
82 prepared = self.prepare_items(items)
---> 83 self.write_items(prepared, buf)
84
~/dev/kafka_sink/venv/lib/python3.7/site-packages/clickhouse_driver/columns/base.py in write_items(self, items, buf)
144 except struct_error as e:
--> 145 raise exceptions.StructPackException(e)
146
StructPackException: required argument is not an integer
During handling of the above exception, another exception occurred:
TypeMismatchError Traceback (most recent call last)
~/dev/kafka_sink/venv/lib/python3.7/site-packages/clickhouse_sqlalchemy/drivers/native/connector.py in executemany(self, operation, seq_of_parameters, context)
164 operation, params=seq_of_parameters,
--> 165 external_tables=external_tables, settings=settings
166 )
~/dev/kafka_sink/venv/lib/python3.7/site-packages/clickhouse_driver/client.py in execute(self, query, params, with_column_types, external_tables, query_id, settings, types_check, columnar)
204 query, params, external_tables=external_tables,
--> 205 query_id=query_id, types_check=types_check
206 )
~/dev/kafka_sink/venv/lib/python3.7/site-packages/clickhouse_driver/client.py in process_insert_query(self, query_without_data, data, external_tables, query_id, types_check)
355 if sample_block:
--> 356 self.send_data(sample_block, data, types_check=types_check)
357 packet = self.connection.receive_packet()
~/dev/kafka_sink/venv/lib/python3.7/site-packages/clickhouse_driver/client.py in send_data(self, sample_block, data, types_check)
379 types_check=types_check)
--> 380 self.connection.send_data(block)
381
~/dev/kafka_sink/venv/lib/python3.7/site-packages/clickhouse_driver/connection.py in send_data(self, block, table_name)
478
--> 479 self.block_out.write(block)
480 self.block_out.reset()
~/dev/kafka_sink/venv/lib/python3.7/site-packages/clickhouse_driver/streams/native.py in write(self, block)
40 write_column(self.context, col_name, col_type, items,
---> 41 self.fout, types_check=block.types_check)
42
~/dev/kafka_sink/venv/lib/python3.7/site-packages/clickhouse_driver/columns/service.py in write_column(context, column_name, column_spec, items, buf, types_check)
106 'Column {}: {}'.format(
--> 107 column_name, str(error)
108 )
TypeMismatchError: Code: 53. Type mismatch in VALUES section. Repeat query with types_check=True for detailed info. Column value: required argument is not an integer
During handling of the above exception, another exception occurred:
DatabaseException Traceback (most recent call last)
<ipython-input-210-be61f4dbb946> in <module>
----> 1 session.execute(Rate.__table__.insert(), [{'day':datetime.now(), 'value': None}, {'day':datetime.now(), 'value': 1}])
~/dev/kafka_sink/venv/lib/python3.7/site-packages/sqlalchemy/orm/session.py in execute(self, clause, params, mapper, bind, **kw)
1267
1268 return self._connection_for_bind(bind, close_with_result=True).execute(
-> 1269 clause, params or {}
1270 )
1271
~/dev/kafka_sink/venv/lib/python3.7/site-packages/sqlalchemy/engine/base.py in execute(self, object_, *multiparams, **params)
986 raise exc.ObjectNotExecutableError(object_)
987 else:
--> 988 return meth(self, multiparams, params)
989
990 def _execute_function(self, func, multiparams, params):
~/dev/kafka_sink/venv/lib/python3.7/site-packages/sqlalchemy/sql/elements.py in _execute_on_connection(self, connection, multiparams, params)
285 def _execute_on_connection(self, connection, multiparams, params):
286 if self.supports_execution:
--> 287 return connection._execute_clauseelement(self, multiparams, params)
288 else:
289 raise exc.ObjectNotExecutableError(self)
~/dev/kafka_sink/venv/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _execute_clauseelement(self, elem, multiparams, params)
1105 distilled_params,
1106 compiled_sql,
-> 1107 distilled_params,
1108 )
1109 if self._has_events or self.engine._has_events:
~/dev/kafka_sink/venv/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _execute_context(self, dialect, constructor, statement, parameters, *args)
1246 except BaseException as e:
1247 self._handle_dbapi_exception(
-> 1248 e, statement, parameters, cursor, context
1249 )
1250
~/dev/kafka_sink/venv/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _handle_dbapi_exception(self, e, statement, parameters, cursor, context)
1466 util.raise_from_cause(sqlalchemy_exception, exc_info)
1467 else:
-> 1468 util.reraise(*exc_info)
1469
1470 finally:
~/dev/kafka_sink/venv/lib/python3.7/site-packages/sqlalchemy/util/compat.py in reraise(tp, value, tb, cause)
151 if value.__traceback__ is not tb:
152 raise value.with_traceback(tb)
--> 153 raise value
154
155 def u(s):
~/dev/kafka_sink/venv/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _execute_context(self, dialect, constructor, statement, parameters, *args)
1222 if not evt_handled:
1223 self.dialect.do_executemany(
-> 1224 cursor, statement, parameters, context
1225 )
1226 elif not parameters and context.no_parameters:
~/dev/kafka_sink/venv/lib/python3.7/site-packages/clickhouse_sqlalchemy/drivers/base.py in do_executemany(self, cursor, statement, parameters, context)
584
585 def do_executemany(self, cursor, statement, parameters, context=None):
--> 586 cursor.executemany(statement, parameters, context=context)
587
588 def do_execute(self, cursor, statement, parameters, context=None):
~/dev/kafka_sink/venv/lib/python3.7/site-packages/clickhouse_sqlalchemy/drivers/native/connector.py in executemany(self, operation, seq_of_parameters, context)
167
168 except DriverError as orig:
--> 169 raise DatabaseException(orig)
170
171 self._process_response(response, context)
DatabaseException: Orig exception: Code: 53. Type mismatch in VALUES section. Repeat query with types_check=True for detailed info. Column value: required argument is not an integer
Could you please tell what I am doing wrong. I just want to insert None value to nullable columns like I would do in oiriginal python clickhouse_driver.