云日志服务 LTS-LTS-Flink-Connector参数说明:WITH参数
WITH参数
- 通用参数
表2 通用参数说明 参数名称
描述
类型
是否必填
默认值
connector
表类型。
String
必填
lts
regionName
云日志 服务的区域
String
必填
-
projectId
华为云账号的项目ID(project id)
String
必填
-
logGroupId
LTS的日志组ID
String
必填
-
logStreamId
LTS的日志流ID
String
必填
-
logGroupName
LTS的日志组名称
String
选填
日志组ID和名称不能同时为空。
logStreamName
LTS的日志流名称
String
选填
日志流ID和名称不能同时为空。
accessKey
华为云账号的AK
String
必填
-
accessSecret
华为云账号的SK
String
必填
-
consumerGroup
LTS日志流对应的消费组名称
String
必填
-
startTime
消费开始时间:ns时间戳(指定时间消费)、begin_cursor(从头开始消费)、end_cursor(从最新数据开始消费)
String
必填
-
stopTime
ns时间戳 (消费结束时间)
Long
选填
-
jsonParse
是否对原始日志做json解析
Boolean
选填
false
enableLocalTest
是否开启跨云消费日志(flink-connector版本最低必须为1.0.7支持此功能)。此功能仅适用于开发调测,对于消费性能不做保障。
- 选true时,开启跨云后用户能通过公网(华东-上海一)访问。
- 选false时,关闭跨云后用户是通过华为云当前区域主机访问。
boolean
选填
false
historyQuery
是否消费历史数据(flink-connector版本最低必须为1.0.7支持此功能)。
- 选true时,可以消费开启日志流引擎之前的数据。
- 选false时,只能消费当开启了日志流引擎之后的数据。
boolean
选填
false
proxyIp
使用自定义ip端口上报日志(flink-connector版本最低必须为1.1.0支持此功能)。
String
选填
-
timeField
指定字段名,该字段的值会覆盖__time__属性字段的值,表示日志写入时间。(flink-connector版本最低必须为1.1.3支持此功能)
String
选填
该参数值是表中已存在的字段之一,且字段必须为ms时间戳的INT类型。如果未指定,则默认填充当前时间。