本文为您介绍日志服务SLS结果表的DDL定义、WITH参数、类型映射和相关文档。
什么是日志服务
日志服务SLS是针对日志类数据的一站式服务。日志服务可以帮助您快捷地完成数据采集、消费、投递以及查询分析,提升运维和运营效率,建立海量日志处理能力。日志服务本身是流数据存储,Flink支持将其作为流式数据的输出。
前提条件
已创建日志服务Project和Logstore,详情请参见步骤二:创建Project和Logstore。
使用限制
仅Flink计算引擎VVR 2.0.0及以上版本支持日志服务SLS Connector。
DDL定义
create table sls_sink(
name varchar,
age int,
birthday int
)with(
'connector'='sls',
'endPoint'='<endPoint>',
'accessId'='<yourAccessId>',
'accessKey'='<yourAccessKey>',
'project'='<yourProjectName>',
'logstore'='<yourLogstoreName>'
);
WITH参数
参数 | 说明 | 是否必填 | 备注 |
---|---|---|---|
connector | 结果表类型。 | 是 | 固定值为sls 。
|
endPoint | EndPoint地址。 | 是 | 服务入口。 |
project | 项目名。 | 是 | 无。 |
logstore | 表名。 | 是 | 无。 |
accessId | 阿里云账号的AccessKey ID。 | 是 | 无。 |
accessKey | 阿里云账号的AccessKey Secret。 | 是 | 无。 |
topicField | 指定字段名,该字段的值会覆盖__topic__属性字段的值,表示日志的主题。 | 否 | 该参数值应当是表中已存在的字段之一,默认值为空。 |
timeField | 指定字段名,该字段的值会覆盖__timestamp__属性字段的值,表示日志写入时间。 | 否 | 该参数值应当是表中已存在的字段之一(类型必须为INT)。如果未指定,则默认填充当前时间。 |
sourceField | 指定字段名,该字段的值会覆盖__source__属性字段的值,表示日志的来源地,例如产生该日志机器的IP地址。 | 否 | 该参数值应当是表中已存在的字段之一,默认值为空。 |
flushIntervalMs | 触发数据写入的时间周期。 | 否 | 默认值为2000,单位为毫秒。 |
类型映射
日志服务和Flink字段类型对应关系如下,建议您使用该对应关系进行DDL声明。
日志服务字段类型 | Flink字段类型 |
---|---|
STRING | VARCHAR |