本文为您介绍日志服务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