数据湖探索 DLI-SMN结果表:示例

时间:2024-11-16 13:21:41

示例

将数据写入smn的相应主题中,其中smn发送的消息的主题为'test',内容为字段'attr1'的内容

create table smnSink (
  attr1 STRING,
  attr2 STRING
)
with (
  'connector.type' = 'smn',
  'connector.region' = 'cn-north-1',
  'connector.topic-urn' = 'xxxxxx',
  'connector.message-subject' = 'test',
  'connector.message-column' = 'attr1'
);
support.huaweicloud.com/sqlref-flink-dli/dli_08_0314.html