File tree Expand file tree Collapse file tree 1 file changed +11
-13
lines changed
Expand file tree Collapse file tree 1 file changed +11
-13
lines changed Original file line number Diff line number Diff line change @@ -51,23 +51,21 @@ pip install -e .[dev]
5151### 🐍 Python usage:
5252
5353``` python
54- python
55- Копировать
56- Редактировать
54+
5755from insert_tools.pipeline import InsertPipeline
5856from insert_tools.sink.clickhouse import ClickhouseSink
5957
6058pipeline = InsertPipeline(
61- select_sql = " SELECT * FROM source_table" ,
62- sink = ClickhouseSink(
63- host = " localhost" ,
64- database = " default" ,
65- target_table = " my_table" ,
66- user = " default" ,
67- password = " admin123" ,
68- ),
69- allow_type_cast = True ,
70- strict_column_match = True ,
59+ select_sql = " SELECT * FROM source_table" ,
60+ sink = ClickhouseSink(
61+ host = " localhost" ,
62+ database = " default" ,
63+ target_table = " my_table" ,
64+ user = " default" ,
65+ password = " admin123" ,
66+ ),
67+ allow_type_cast = True ,
68+ strict_column_match = True ,
7169)
7270
7371pipeline.run()
You can’t perform that action at this time.
0 commit comments