diff --git a/clickhouse_mysql/writer/chwriter.py b/clickhouse_mysql/writer/chwriter.py index 587d48f..2077030 100644 --- a/clickhouse_mysql/writer/chwriter.py +++ b/clickhouse_mysql/writer/chwriter.py @@ -74,6 +74,7 @@ def insert(self, event_or_events=None): event_converted = self.convert(event) for row in event_converted: for key in row.keys(): + row[key] = '' if row[key] is None else row[key] # we need to convert Decimal value to str value for suitable for table structure if type(row[key]) == Decimal: row[key] = str(row[key])