本文为您介绍日志服务SLS结果表的DDL定义、WITH参数、类型映射和相关文档。

什么是日志服务

日志服务SLS是针对日志类数据的一站式服务。日志服务可以帮助您快捷地完成数据采集、消费、投递以及查询分析,提升运维和运营效率,建立海量日志处理能力。日志服务本身是流数据存储,Flink支持将其作为流式数据的输出。

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
flushIntervalMs 触发数据写入的周期 默认值为2000,单位为毫秒。

类型映射

日志服务和Flink字段类型对应关系如下,建议您使用该对应关系进行DDL声明。

日志服务字段类型 Flink字段类型
STRING VARCHAR

相关文档

日志服务帮助文档,请参见什么是日志服务