工作流调度简介

参数

类型

示例值

描述

TimeZone

String

GMT+8:00

时区。

Schedule

String

0 */10 * * * *

触发周期为自定义Corn时的Corn表达式。

UserData

Object

{"key":"value"}

填写的自定义参数，格式为JSON对象。

参数

类型

示例值

描述

headers

Object

{

"Accept": "application/json"

}

HTTP请求头的内容。

path

String

/webhook/putEvents

请求路径。

body

Object

{

"filePath": "/tmp/uploader"

}

HTTP请求体的内容。

httpMethod

String

GET

HTTP调用方法。

queryString

String

username=leo

HTTP URL中query的内容，不包括请求Webhook的Token。

参数

类型

示例值

描述

key1

String

testKey

"key1": "value1"、"key2": "value2"表示用户的SLS日志中的字段及对应内容。

__topic__

String

testTopic

日志主题。

__source__

String

testSource

日志来源设备。

__client_ip__

String

122.231.XX.XX

日志所在主机的IP地址。

__receive_time__

String

1663487595

日志到达服务端的时间。

__pack_id__

String

59b662b2257796****

该日志所属的LogGroup的唯一身份标识。

参数

类型

示例值

描述

requestId

String

606EA3074344430D4C81****

请求ID。每个请求的ID取值唯一。

messageId

String

C6DB60D1574661357FA227277445****

消息ID。每条消息的ID取值唯一。

messageBody

String

TEST

消息内容。

参数

类型

示例值

描述

topic

String

TopicName

Topic名称。

systemProperties

Map

系统属性。

MIN_OFFSET

Int

0

最低位点。

TRACE_ON

Boolean

true

是否有消息轨迹。取值说明如下：

• true：有消息轨迹。

• false：无消息轨迹。

MAX_OFFSET

Int

8

最高位点。

MSG_REGION

String

cn-hangzhou

发送消息的地域。

KEYS

String

systemProperties.KEYS

过滤属性。

CONSUME_START_TIME

Long

1628577790396

开始消费时间。单位：毫秒。

UNIQ_KEY

String

AC14C305069E1B28CDFA3181CDA2****

消息唯一键。

TAGS

String

systemProperties.TAGS

过滤属性。

INSTANCE_ID

String

MQ_INST_123456789098****_BXhFHryi

实例ID。

userProperties

Map

无

用户属性。

body

String

TEST

消息内容。

参数

类型

示例值

描述

body

Map

消息内容。

Hello

String

EventBridge

用户数据。

props

Map

消息属性。

contentEncoding

String

utf-8

消息内容编码。

messageId

String

f7622d51-e198-41de-a072-77c1ead7****

消息ID。每条消息的ID取值唯一。

envelope

Map

消息的envelope信息。

deliveryTag

Int

98

消息的Tag。

exchange

String

无

消息的Exchange。

redeliver

Boolean

false

是否支持重发消息。取值说明如下：

• true：支持

• false：不支持

routingKey

String

housekeeping

消息的路由规则。

参数

类型

示例值

描述

topic

String

TopicName

Topic的名称。

partition

Int

1

消息队列Kafka版的消费分区信息。

offset

Int

0

消息队列Kafka版的消息位点。

timestamp

String

1655952591589

开始消费时间戳。

参数

类型

示例值

描述

id

String

321****

DTS数据ID。

topicPartition

Array

Topic的分区信息。

hash

String

0

DTS底层存储参数。

partition

String

0

Topic的分区。

topic

String

cn_hangzhou_rm_1234****_test_version2

Topic的名称。

offset

Int

3218099

DTS数据对应的消息存储位点。

sourceTimestamp

Int

1654847757

DTS数据生成时间戳。

operationType

String

UPDATE

DTS数据的操作类型。

schema

Array

数据库表结构信息。

recordFields

Array

字段详情记录。

fieldName

String

id

字段名称。

rawDataTypeNum

Int

8

字段类型映射值。

isPrimaryKey

Boolean

true

字段是否是主键。

isUniqueKey

Boolean

false

字段是否是唯一值。

fieldPosition

String

0

字段位置。

nameIndex

Array

命名索引。

schemaId

String

(hangzhou-test-db,hangzhou-test-db,message_info)

数据库表结构信息的ID。

databaseName

String

hangzhou--test-db

数据库名称。

tableName

String

message_info

数据表名称。

primaryIndexInfo

Array

主键索引。

indexType

String

PrimaryKey

主键索引类型。

indexFields

Array

主键索引字段内容。

cardinality

String

0

主键基数。

nullable

Boolean

true

主键是否可为null。

isFirstUniqueIndex

Boolean

false

是否是第一个唯一索引。

uniqueIndexInfo

String

[]

唯一索引。

foreignIndexInfo

String

[]

外键索引。

normalIndexInfo

String

[]

普通索引。

databaseInfo

Array

数据库信息。

databaseType

String

MySQL

数据库类型。

version

String

5.7.35-log

数据库版本。

totalRows

Int

0

数据表的总行数。

beforeImage

String

操作前记录字段内容镜像。

values

String

记录字段的值。

size

Int

47

记录字段大小。

afterImage

String

操作后记录字段内容镜像。

参数

类型

示例值

描述

props

Map

消息属性。

firstTopic

String

housekee****

用于收发消息的父级Topic。

secondTopic

String

/testMq4****

子级Topic。

clientId

String

GID_****

客户端ID。

body

String

TEST

消息内容。