云日志服务 LTS-LTS-Flink-Connector参数说明:代码示例
时间：2025-04-17 17:44:24
下载云日志服务 LTS用户手册完整版
复制链接到剪贴板
分享文章到微博
分享文章到朋友圈
代码示例
认证用的ak和sk硬编码到代码中或者明文存储都有很大的安全风险，建议在配置文件或者环境变量中密文存放，使用时解密，确保安全。
CREATE TABLE source (
filed1 varchar,
filed2 varchar,
filed3 varchar
)with (
'connector' = 'lts',
'regionName' = 'cn-north-4',
'projectId' = '{projectId}',
'accessKey' = '{ak}',
'accessSecret' = '{sk}',
'logGroupId' = '{groupId}',
'logStreamId' = '{streamId}',
'consumerGroup' = '{consumerGroup}',
'startTime' = '1689836602157000000',
'jsonParse' = 'false'
);
CREATE TABLE print_sink (
filed1 varchar,
filed2 varchar,
filed3 varchar
)with (
'connector' = 'lts',
'regionName' = 'cn-north-4',
'projectId' = '{projectId}',
'accessKey' = '{ak}',
'accessSecret' = '{sk}',
'logGroupId' = '{groupId}',
'logStreamId' = '{streamId}'
);
insert into print_sink select * from source;support.huaweicloud.com/usermanual-lts/lts_07_0051.html
