使用场景
离线传输,源端数据源为ES时,传输任务如何获取ES端的元数据(_id,_type等),eg:
INFO-离线传输,来源es时如何读取metadata字段,例如_id、_index等 - 图1
示例
有两种实现方式:
方式一:
1、选择系统推断字段类型
2、添加参数:source.es.read.metadata=true
3、然后自定义表达式写_metadata._id as 去向列名
INFO-离线传输,来源es时如何读取metadata字段,例如_id、_index等 - 图2

方式二:
1、选择读取成string
INFO-离线传输,来源es时如何读取metadata字段,例如_id、_index等 - 图3
2、添加参数:source.es.read.metadata=true
3、然后自定义表达式写 get_json_object(${source json}, '$._metadata._id') as 去向列名

作者:曹俊