MaxCompute Sink组件使用说明

组件说明

MaxCompute Sink 组件。用于将数据写入 MaxCompute 数据库。

配置项说明

配置名称	数据类型	是否必填	默认值	描述
节点名称	String	是	MaxCompute	当前创建的节点名称，由用户自定义且不可为空。命名可包含字母、数字、下划线。确保唯一性。
节点编码	String	是	自动生成	当前创建的节点编码，以此标识此组件，由用户自定义且不可为空。命名可包含字母、数字、下划线。确保唯一性。
选择数据源	String	是	-	从下拉选项中选择列出的当前项目已经关联的数据源。
选择表	String	是	-	从下拉列表中选择数据表。
分区信息	String	否	-	指定分区。单级分区：lpt="20250520’ 多级分区(使用逗号隔开)：dt="202505",hr="12",city="beijing"。若不填，则写入非分区表；若表为分区表且未指定，可能导致写入失败
启用upsert语法	Boolean	否	否	当目标表为主键表时，upsert 模式必须是 true。
是否覆盖表/分区	Boolean	否	否	是：覆盖整表或指定分区否：追加写入
表添加模式	String	否	表不存在时创建	对于目标表的情况，处理方式有四种： - 重新创建表 - 表不存在时创建 - 表不存在时报告错误 - 忽略对表的处理
数据添加模式	String	否	追加数据	支持四种模式： 1、追加数据：保留表结构，保留原数据（追加写入）； 2、同步前删除数据：保留表结构，清空数据； 3、当存在数据时，报告错误：表中存在数据时报错。 4、自定义处理：用户自定义预处理SQL（需配合custom_sql参数）。
缓冲区大小	Int	是	64	缓冲区大小，单位：MB。
缓冲区刷新阈值	Int	否	90	缓冲区刷新阈值，单位：%。
超时时间	Int	否	120000	超时时间，单位：毫秒。
可选参数	Map	否	-	可以根据需求进行配置。可选参数名称可以参考 Seatunnel 官方手册。 json 格式如： { "clickhouse.config": "{ "max_rows_to_read" :100, "read_overflow_mode": "throw" }" }

FAQ