事件目标参数

更新时间:2024-10-21 08:51:46

本文介绍事件目标中的元数据参数。

请求参数

参数

类型

是否必选

示例值

描述

参数

类型

是否必选

示例值

描述

EventBusName

String

default

事件总线的名称。更多信息,请参见使用限制

RuleName

String

MNSRule

事件规则的名称。更多信息,请参见使用限制

Description

String

MNS的过滤规则。

规则说明。

Status

String

ENABLE

规则的状态。取值说明如下:

  • ENABLE:规则已启用。

  • DISABLE:规则已禁用。

默认值:ENABLE。

FilterPattern

String

{\"source\": [{\"prefix\": \"acs.\"}],\"type\": [{\"prefix\":\"oss:ObjectReplication\"}],\"subject\":[{\"prefix\":\"acs:oss:cn-hangzhou:123456789098****:my-movie-bucket/\", \"suffix\":\".txt\"}]}

事件模式。格式为JSON。取值说明,请参见事件模式

Targets

List<Target>

事件的投递目标。

Id

String

1

自定义的事件目标ID,在当前规则下不可重名。

Type

String

acs.mns.queue

事件目标类型。更多信息,请参考下文关于各事件目标的详细介绍。

Endpoint

String

acs:mns:cn-hangzhou:123456789098****:queues/myqueue

投递端点链接。更多信息,请参考下文关于各事件目标的Endpoint格式。

PushRetryStrategy

String

BACKOFF_RETRY

推送重试策略。取值说明如下:

  • BACKOFF_RETRY:退避重试策略。重试3次,每次重试的间隔时间是10秒到20秒之间的随机值。

  • EXPONENTIAL_DECAY_RETRY:指数衰减重试。重试176次,每次重试的间隔时间指数递增至512秒,总计重试时间为1天。每次重试的具体间隔为:1,2,4,8,16,32,64,128,256,512,512,...,512秒(共重试167512秒)。

DeadLetterQueue

String

死信队列。未处理或者超过重试次数的事件会被写入死信。支持的队列类型有轻量消息队列(原 MNS)云消息队列 RocketMQ 版

Arn

String

acs:mns:cn-hangzhou:123456789098****:/queues/rule-deadletterqueue或者acs:mq:cn-hangzhou:123456789098****:/instances/myinstance/topic/mytopic

死信队列的Arn,未处理或超过重试次数的事件会被写入死信。支持的队列类型有轻量消息队列(原 MNS)云消息队列 RocketMQ 版

ParamList

List<Param>

事件传递的参数。

resourceKey

String

body

目标服务的参数。

form

String

TEMPLATE

事件转换的格式。有四种类型:

  • ORIGINAL:完整事件。无需定义valuetemplate事件总线EventBridge不对事件进行转换,将原生CloudEvents的完整结构路由到事件目标。更多信息,请参见完整事件

  • JSONPATH:部分事件。无需定义template,只需定义value事件总线EventBridge通过JSONPathCloudEvents中提取事件中的参数,将指定的事件内容路由到事件目标。更多信息,请参见部分事件

    value示例值如下所示。

    $.data.name
  • CONSTANT:常量。无需定义template,只需定义value。无论事件内容是什么,事件总线EventBridge只把value定义的常量路由到事件目标。更多信息,请参见常量

    value示例值如下所示。

    "test1"
  • TEMPLATE:模板。需定义valuetemplate事件总线EventBridge通过JSONPathCloudEvents提取事件中的参数,把参数值存放在value中,然后按照template定义的格式路由到事件目标。更多信息,请参见模板

    value示例值如下所示。

    {
        "name":"$.data.name",
        "constant":"Please deal with it timely."
    }

    template示例值如下所示。

    The instance is broken,which name is ${name} , ${constant}

value

String

{\"key\"=\"value\"}

事件转换的值。

template

String

The value of ${key} is ${value}!

事件转换模板样式。

返回参数

参数

类型

示例值

描述

参数

类型

示例值

描述

RuleARN

String

acs:eventbridge:cn-hangzhou:123456789098****:eventbus/default/rule/MNSRule

事件规则的ARN,用于授权。

钉钉

当事件目标选择钉钉时,元数据参数中的Type值为acs.dingtalkEndpoint表示配置的钉钉URL地址,ParamList中的resourceKey字段含义如下表所示。

resourceKey

是否必传

form

value

template

resourceKey

是否必传

form

value

template

URL

CONSTANT

URL地址。

SecretKey

CONSTANT

密钥。

Body

TEMPLATE

定义TEMPLATEKeyValue。

定义消息体的模板。

JSONPath示例如下:

{
    "Id":"KD20k9rpqDRXPq0SXXlqeT****",
    "Type":"acs.dingtalk",
    "Endpoint":"https://oapi.dingtalk.com/robot/send?access_token=1560abe367f48877c69bb6a9916244979927abbbbf82f4fe8801692cd6ea****",
    "ParamList":[
        {
            "Value":"https://oapi.dingtalk.com/robot/send?access_token=1560abe367f48877c69bb6a9916244979927abbbbf82f4fe8801692cd6ea****",
            "ResourceKey":"URL",
            "Form":"CONSTANT"
        },
        {
            "Value":"SEC1eca5209e0c6c23165b9504967522d47b0d0004e1caf3a75f6ddfda7359d****",
            "ResourceKey":"SecretKey",
            "Form":"CONSTANT"
        },
        {
            "Value":{
                "content":"$.data.content"
            },
            "ResourceKey":"Body",
            "Form":"TEMPLATE",
            "Template":{
                "Msgtype":"text",
                "Text":{
                    "content":"@1851111***** ${content}"
                },
                "At":{

                }
            }
        }
    ]
}

邮箱

当事件目标选择邮箱时,元数据参数中的Type值为acs.mailEndpoint表示配置的邮箱的URL地址,格式为acs:mail:${region}:${uid}ParamList中的resourceKey字段含义如下表所示。

resourceKey

是否必传

form

value

template

resourceKey

是否必传

form

value

template

Subject

CONSTANT

主题。

AccountName

CONSTANT

发信地址。

AddressType

CONSTANT

地址类型。

ReplyToAddress

CONSTANT

回信地址。

ToAddress

  • CONSTANT

  • JSONPATH

收件人地址。

IsHtmlBody

CONSTANT

是否为HTML正文。取值如下:

  • true:是HTML正文。

  • false:不是HTML正文。

Body

TEMPLATE

定义TEMPLATEKeyValue。

定义消息体的模板。

JSONPath示例如下:

{
    "Id":"KD20k9rpqDRXPq0SXXlqeT****",
    "Type":"acs.mail",
    "Endpoint":"acs:mail:cn-hangzhou:164901546557****",
    "ParamList":[
        {
            "Value":"test",
            "ResourceKey":"Subject",
            "Form":"CONSTANT"
        },
        {
            "Value":"example.com",
            "ResourceKey":"AccountName",
            "Form":"CONSTANT"
        },
        {
            "Value":"1",
            "ResourceKey":"AddressType",
            "Form":"CONSTANT"
        },
        {
            "Value":"true",
            "ResourceKey":"ReplyToAddress",
            "Form":"CONSTANT"
        },
        {
            "Value":"$.data.name",
            "EsourceKey":"ToAddress",
            "Form":"JSONPATH"
        },
        {
            "Value":"true",
            "ResourceKey":"IsHtmlBody",
            "Form":"CONSTANT"
        },
        {
            "Value":{
                "Mobile":"$.data.mobile",
                "Subject":"$.subject"
            },
            "ResourceKey":"Body",
            "Form":"TEMPLATE",
            "Template":{
                "Code":"${subject}"
            }
        }
    ]
}

短信

当事件目标选择短信时,元数据参数中的Type值为acs.smsEndpoint表示配置短信的URL地址,格式为acs:sms:${region}:${uid}ParamList中的resourceKey字段含义如下表所示。

resourceKey

是否必传

form

value

template

resourceKey

是否必传

form

value

template

PhoneNumbers

  • CONSTANT

  • JSONPATH

手机号码。

SignName

CONSTANT

签名名称。

TemplateCode

CONSTANT

短信服务的模板Code。

TemplateParam

TEMPLATE

定义TEMPLATEKeyValue。

定义消息体的模板。

JSONPath示例如下:

{
    "Id":"KD20k9rpqDRXPq0SXXlqeT****",
    "Type":"acs.sms",
    "Endpoint":"acs:sms:cn-hangzhou:164901546557****",
    "ParamList":[
        {
            "Value":"$.data",
            "ResourceKey":"PhoneNumbers",
            "Form":"JSONPATH"
        },
        {
            "Value":"[测试专用]阿里云通信",
            "ResourceKey":"SignName",
            "Form":"CONSTANT"
        },
        {
            "Value":" [测试专用]阿里云通信测试模版",
            "ResourceKey":"TemplateCode",
            "Form":"CONSTANT"
        },
        {
            "Value":{
                "Mobile":"$.data.mobile",
                "Subject":"$.subject"
            },
            "ResourceKey":"TemplateParam",
            "Form":"TEMPLATE",
            "Template":{
                "Code":"${subject}"
            }
        }
    ]
}

函数计算

当事件目标选择函数计算时,元数据参数中的Type值为acs.fc.functionEndpoint表示配置的URL地址,格式为acs:fc:${region}:${uid}:services/${serviceName}.${Qualifier}/functions/${functionName}ParamList中的resourceKey字段含义如下表所示。

resourceKey

是否必传

form

value

template

resourceKey

是否必传

form

value

template

serviceName

CONSTANT

服务。

functionName

CONSTANT

函数。

Body

  • ORIGINAL

  • CONSTANT

  • JSONPATH

  • TEMPLATE

函数的消息体内容,定义TEMPLATEKeyValue。

定义消息体的模板。

InvocationType

CONSTANT

调用类型。取值如下:

  • Sync:同步调用。

  • Async:异步调用。

JSONPath示例如下:

{
    "Id":"KD20k9rpqDRXPq0SXXlqeT****",
    "Type":"acs.fc.function",
    "Endpoint":"acs:fc:cn-hangzhou:164901546557****:services/guide-hello_world.LATEST/functions/hello_world",
    "ParamList":[
        {
            "Value":"guide-hello_world",
            "ResourceKey":"serviceName",
            "Form":"CONSTANT"
        },
        {
            "Value":"hello_world",
            "ResourceKey":"functionName",
            "Form":"CONSTANT"
        },
        {
            "Value":"$.data.name",
            "ResourceKey":"Body",
            "Form":"JSONPATH"
        },
        {
            "Value":"LATEST",
            "ResourceKey":"Qualifier",
            "Form":"CONSTANT"
        }
    ]
}

轻量消息队列

当事件目标选择轻量消息队列(原 MNS)时,元数据参数中的Type值为acs.mns.queueEndpoint表示配置的URL地址,格式为acs:mns:${region}:${uid}:queues/${queue}ParamList中的resourceKey字段含义如下表所示。

resourceKey

是否必传

form

value

template

resourceKey

是否必传

form

value

template

queue

CONSTANT

队列。

Body

  • ORIGINAL

  • CONSTANT

  • JSONPATH

  • TEMPLATE

根据form配置消息内容。

如果form选择TEMPLATE,则在此处配置模板。

JSONPath示例如下:

{
    "Id":"KD20k9rpqDRXPq0SXXlqeT****",
    "Type":"acs.mns.queue",
    "Endpoint":"acs:mns:cn-hangzhou:164901546557****:queues/MyQueue",
    "ParamList":[
        {
            "Value":"MyQueue",
            "ResourceKey":"queue",
            "Form":"CONSTANT"
        },
        {
            "Value":{
                "Source":"$.source"
            },
            "ResourceKey":"Body",
            "Form":"TEMPLATE",
            "Template":"The event comes from ${source} is abnormal."
        }
    ]
}

云消息队列 RocketMQ 版

当事件目标选择云消息队列 RocketMQ 版时,元数据参数中的Type值为acs.rocketmqEndpoint表示配置的URL地址,格式为acs:mq:${region}:${uid}:/instances/${instanceId}/topic/${topic}ParamList中的resourceKey字段含义如下表所示。

resourceKey

是否必传

form

value

template

resourceKey

是否必传

form

value

template

InstanceId

CONSTANT

实例ID。

Topic

CONSTANT

主题。

Body

  • ORIGINAL

  • JSONPATH

  • CONSTANT

  • TEMPLATE

消息体。

如果form选择TEMPLATE,则在此处配置模板。

Properties

  • JSONPATH

  • TEMPLATE

属性。

Keys

  • JSONPATH

  • CONSTANT

  • TEMPLATE

关键标识。

如果form选择TEMPLATE,则在此处配置模板。

Tags

  • JSONPATH

  • CONSTANT

  • TEMPLATE

标签。

如果form选择TEMPLATE,则在此处配置模板。

JSONPath示例如下:

{
    "Id":"KD20k9rpqDRXPq0SXXlqeT****",
    "Type":"acs.rocketmq",
    "Endpoint":"acs:mq:cn-hangzhou:164901546557****:/instances/${instanceId}/topic/${topic}",
    "ParamList":[
        {
            "Value":"MQ_INST_164901546557****_BAAQ4gWo",
            "ResourceKey":"InstanceId",
            "Form":"CONSTANT"
        },
        {
            "Value":"test-topic1",
            "ResourceKey":"Topic",
            "Form":"CONSTANT"
        },
        {
            "Value":"$.data.name",
            "ResourceKey":"Body",
            "Form":"JSONPATH"
        },
        {
            "Value":"$.data.userProperties",
            "ResourceKey":"Properties",
            "Form":"JSONPATH"
        },
        {
            "Value":"$.data.systemProperties.KEYS",
            "ResourceKey":"Keys",
            "Form":"JSONPATH"
        },
        {
            "Value":"$.data.systemProperties.TAGS",
            "ResourceKey":"Tags",
            "Form":"JSONPATH"
        }
    ]
}

云消息队列 RabbitMQ 版

当事件目标选择云消息队列 RabbitMQ 版时,元数据参数中的Type值为acs.rabbitmqEndpoint表示配置的URL地址,格式为acs:amqp:${region}:${uid}:/instances/${instanceId}/vhosts/${vhostName}/exchanges/${exchangeName}ParamList中的resourceKey字段含义如下表所示。

resourceKey

是否必传

form

value

template

resourceKey

是否必传

form

value

template

InstanceId

CONSTANT

实例ID。

Vhost

CONSTANT

虚拟机。

TargetType

CONSTANT

目标类型。

说明

参数ExchangeQueue同时只能选择其中一个。

Exchange

否,仅当TargetType取值为Exchange时必传。

CONSTANT

Exchange模式。

Queue

否,仅当TargetType取值为Queue时必传。

CONSTANT

说明

参数ExchangeQueue同时只能选择其中一个。

Queue模式。

Body

  • ORIGINAL

  • JSONPATH

  • CONSTANT

  • TEMPLATE

消息体。

如果form选择TEMPLATE,则在此处配置模板。

MessageId

否,默认自动生成。

  • JSONPATH

  • CONSTANT

  • TEMPLATE

消息ID。

如果form选择TEMPLATE,则在此处配置模板。

Properties

  • JSONPATH

  • TEMPLATE

属性。

如果form选择TEMPLATE,则在此处配置模板。

JSONPath示例如下:

示例一:目标类型Exchange

{
    "Id":"KD20k9rpqDRXPq0SXXlqeT****",
    "Type":"acs.rabbitmq",
    "Endpoint":"acs:amqp:cn-hangzhou:164901546557****:/instances/${instanceId}/vhosts/${vhostName}/exchanges/${exchangeName}",
    "ParamList":[
        {
            "Value":"amqp-cn-i7m29o3s****",
            "ResourceKey":"InstanceId",
            "Form":"CONSTANT"
        },
        {
            "Value":"test.host",
            "ResourceKey":"Vhost",
            "Form":"CONSTANT"
        },
        {
            "Value":"Exchange",
            "ResourceKey":"TargetType",
            "Form":"CONSTANT"
        },
        {
            "Value":"amq.direct",
            "ResourceKey":"Exchange",
            "Form":"CONSTANT"
        },
        {
            "Value":"$.data.name",
            "ResourceKey":"RoutingKey",
            "Form":"JSONPATH"
        },
        {
            "Value":"$.data.name",
            "ResourceKey":"Body",
            "Form":"JSONPATH"
        },
        {
            "Value":"$.data.message",
            "ResourceKey":"MessageId",
            "Form":"JSONPATH"
        },
        {
            "Value":"$.data.userProperties",
            "ResourceKey":"Properties",
            "Form":"JSONPATH"
        }
    ]
}

示例二:目标类型Queue

{
    "Id":"EldwXoVAws5Ix8VpVmrDmr****",
    "Type":"acs.rabbitmq",
    "Endpoint":"acs:amqp:cn-hangzhou:164901546557****:/instances/${instanceId}/vhosts/${vhostName}/exchanges/${exchangeName}",
    "ParamList":[
        {
            "Value":"amqp-cn-i7m29o3s****",
            "ResourceKey":"InstanceId",
            "Form":"CONSTANT"
        },
        {
            "Value":"test.host",
            "ResourceKey":"Vhost",
            "Form":"CONSTANT"
        },
        {
            "Value":"Queue",
            "ResourceKey":"TargetType",
            "Form":"CONSTANT"
        },
        {
            "Value":"test.event",
            "ResourceKey":"Queue",
            "Form":"CONSTANT"
        },
        {
            "Value":"$.data.body",
            "ResourceKey":"Body",
            "Form":"JSONPATH"
        },
        {
            "Value":"$.data.message",
            "ResourceKey":"MessageId",
            "Form":"JSONPATH"
        },
        {
            "Value":"$.data.userproperties",
            "ResourceKey":"Properties",
            "Form":"JSONPATH"
        }
    ]
}

云消息队列 Kafka 版

当事件目标选择云消息队列 Kafka 版时,元数据参数中的Type值为acs.alikafkaEndpoint表示配置的URL地址,格式为acs:alikafka:${regionId}:${accountId}:topics/${topic}ParamList中的resourceKey字段含义如下表所示。

resourceKey

是否必传

form

value

template

resourceKey

是否必传

form

value

template

InstanceId

CONSTANT

Kafka实例ID。

Topic

CONSTANT

主题名称。

Value

  • CONSTANT

  • ORIGINAL

  • JSONPATH

  • TEMPLATE

消息体。

事件转换的格式。有四种类型:

  • ORIGINAL:完整事件。无需定义valuetemplate事件总线EventBridge不对事件进行转换,将原生CloudEvents的完整结构路由到事件目标。更多信息,请参见完整事件

  • JSONPATH:部分事件。无需定义template,只需定义value事件总线EventBridge通过JSONPathCloudEvents中提取事件中的参数,将指定的事件内容路由到事件目标。更多信息,请参见部分事件

    value示例值如下所示。

    $.data.name
  • CONSTANT:常量。无需定义template,只需定义value。无论事件内容是什么,事件总线EventBridge只把value定义的常量路由到事件目标。更多信息,请参见常量

    value示例值如下所示。

    "test1"
  • TEMPLATE:模板。需定义valuetemplate事件总线EventBridge通过JSONPathCloudEvents提取事件中的参数,把参数值存放在value中,然后按照template定义的格式路由到事件目标。更多信息,请参见模板

    value示例值如下所示。

    {
        "name":"$.data.name",
        "constant":"Please deal with it timely."
    }

    template示例值如下所示。

    The instance is broken,which name is ${name} , ${constant}

Key

JSONPATH

消息键值。

请参见Valuetemplate。

Acks

CONSTANT

确认模式。

JSONPath示例如下:

{
    "id":"1rypRt1I9ET6Aks9Y6NNg6U****",
    "type":"acs.alikafka",
    "endpoint":"acs:alikafka:cn-huhehaote:118609547428****:topics/test-topic",
    "pushSelector":"PARAM_TRANSFORMER",
    "errorsTolerance":"ALL",
    "pushRetryStrategy":"BACKOFF_RETRY",
    "paramList":[
        {
            "value":"alikafka_pre-cn-zpr3fwhe****",
            "resourceKey":"InstanceId",
            "form":"CONSTANT"
        },
        {
            "value":"test-topic",
            "resourceKey":"Topic",
            "form":"CONSTANT"
        },
        {
            "value":"$.data",
            "resourceKey":"Value",
            "form":"JSONPATH"
        },
        {
            "value":"$.data.key",
            "resourceKey":"Key",
            "form":"JSONPATH"
        },
        {
            "value":"0",
            "resourceKey":"Acks",
            "form":"CONSTANT"
        }
    ]
}

日志服务SLS

当事件目标选择日志服务SLS时,元数据参数中的Type值为acs.slsEndpoint表示配置的URL地址,格式为acs:sls:${regionId}:${accountId}:project/${project}/logstore/${logstore}ParamList中的resourceKey字段含义如下表所示。

resourceKey

是否必传

form

value

template

resourceKey

是否必传

form

value

template

Project

CONSTANT

日志项目名称。

LogStore

CONSTANT

日志库名称。

Topic

  • CONSTANT

  • TEMPLATE

  • JSONPATH

日志主题。

事件转换的格式。共有以下四种类型:

  • ORIGINAL:完整事件。无需定义valuetemplate事件总线EventBridge不对事件进行转换,将原生CloudEvents的完整结构路由到事件目标。更多信息,请参见完整事件

  • JSONPATH:部分事件。无需定义template,只需定义value事件总线EventBridge通过JSONPathCloudEvents中提取事件中的参数,将指定的事件内容路由到事件目标。更多信息,请参见部分事件

    value示例值如下所示。

    $.data.name
  • CONSTANT:常量。无需定义template,只需定义value。无论事件内容是什么,事件总线EventBridge只把value定义的常量路由到事件目标。更多信息,请参见常量

    value示例值如下所示。

    "test1"
  • TEMPLATE:模板。需定义valuetemplate事件总线EventBridge通过JSONPathCloudEvents提取事件中的参数,把参数值存放在value中,然后按照template定义的格式路由到事件目标。更多信息,请参见模板

    value示例值如下所示。

    {
        "name":"$.data.name",
        "constant":"Please deal with it timely."
    }

    template示例值如下所示。

    The instance is broken,which name is ${name} , ${constant}

Body

  • CONSTANT

  • ORIGINAL

  • JSONPATH

  • TEMPLATE

日志内容。

请参见Topictemplate。

ContentType

CONSTANT

内容类型。

可选值为JSON、KeyValue,默认为JSON。

  • 选择JSON格式时,投递到SLS的日志索引字段为content,值为参数Body中定义的事件内容。

  • 选择KeyValue格式时,投递到SLS的日志索引字段及值由ContentSchema定义的结构确定。

RoleName

CONSTANT

角色配置。

ContentSchema

CONSTANT

自定义写入SLS日志的索引和值的内容模板。

{
    "Key_1":{
        "form":"CONSTANT",
        "value":"myKey01"
    },
    "Value_1":{
        "form":"JSONPATH",
        "value":"$.data.myValue01"
    }
}

其中字段名“Key_1”、“Value_1”表示一对索引与值。

JSONPath示例如下:

{
    "id":"MwOpn5yyemTlQjE5JwYjme****",
    "type":"acs.sls",
    "endpoint":"acs:sls:cn-hangzhou:182572506381****:project/${project}/logstore/${logstore}",
    "pushSelector":"PARAM_TRANSFORMER",
    "errorsTolerance":"ALL",
    "pushRetryStrategy":"BACKOFF_RETRY",
    "paramList":[
        {
            "value":"testproject37****",
            "resourceKey":"Project",
            "form":"CONSTANT"
        },
        {
            "value":"testlogstore37****",
            "resourceKey":"LogStore",
            "form":"CONSTANT"
        },
        {
            "value":"$.data.topic",
            "resourceKey":"Topic",
            "form":"JSONPATH"
        },
        {
            "value":"KeyValue",
            "resourceKey":"ContentType",
            "form":"CONSTANT"
        },
        {
            "value":"AliyunEventBridgeSLS-248QJd****",
            "resourceKey":"RoleName",
            "form":"CONSTANT"
        },
        {
            "value":"{\"Key_1\":{\"form\":\"CONSTANT\",\"value\":\"name\"},\"Value_1\":{\"form\":\"CONSTANT\",\"value\":\"age\"}}",
            "resourceKey":"ContentSchema",
            "form":"CONSTANT"
        }
    ]
}

HTTP/HTTPS

当事件目标选择HTTP/HTTPS时,元数据参数中的Type值为http或者httpsEndpoint表示配置的URL地址,ParamList中的resourceKey字段含义如下表所示。

resourceKey

是否必传

form

value

template

resourceKey

是否必传

form

value

template

url

CONSTANT

URL地址。

Body

  • ORIGINAL

  • CONSTANT

  • JSONPATH

  • TEMPLATE

目前仅支持HTTP Body,如果需要使用Header、Query,请参考管理API端点

formTEMPALTE,则此处配置对应模板,模板中的变量来自于value。

Network

CONSTANT

网络类型。取值说明如下:

  • PublicNetwork:公网。

  • PrivateNetwork:VPC网络,如果选择此项,需要配置VPC、vSwitchSecurityGroup信息。

VPCNameAndId

否,当Network取值为PrivateNetwork时必传。

CONSTANT

目标端所在的VPC信息,格式:VPCName+"/" + VPCId

VSwitchesNameAndId

否,当Network取值为PrivateNetwork时必传。

CONSTANT

目标端所在VPCvSwitch信息,支持多个vSwitch。格式为JsonString。例如:[VSwitchName+"/"+VSwitchId , VSwitchName+"/"+VSwitchId ]

SecurityGroupNameAndId

否,当Network取值为PrivateNetwork时必传。

CONSTANT

目标端所在VPC的安全组信息,格式:SecurityGroupName+"/" + SecurityGroupId

Token

否,默认为空。

CONSTANT

用于签名校验,Header Key固定为:"x-eventbridge-signature-token", Value 为填入值。

JSONPath示例如下:

示例一:网络类型公网

{
    "Id":"KD20k9rpqDRXPq0SXXlqeT****",
    "Type":"https",
    "Endpoint":"http(s)://www.****.com/product/aliware/eventbridge",
    "ParamList":[
        {
            "Value":"http(s)://www.****.com/product/aliware/eventbridge",
            "ResourceKey":"url",
            "Form":"CONSTANT"
        },
        {
            "Value":"",
            "ResourceKey":"Body",
            "Form":"ORIGINAL"
        },
        {
            "Value":"PublicNetwork",
            "ResourceKey":"Network",
            "Form":"CONSTANT"
        }
    ]
}

示例二:网络类型专有网络

{
    "Id":"ZOiNcqqzTGSrDJanZQ72vj****",
    "Type":"http",
    "Endpoint":"http(s)://192.168.XX.XX:8080",
    "ParamList":[
        {
            "Value":"http(s)://192.168.XX.XX:8080",
            "ResourceKey":"url",
            "Form":"CONSTANT"
        },
        {
            "Value":"",
            "ResourceKey":"Body",
            "Form":"ORIGINAL"
        },
        {
            "Value":"PrivateNetwork",
            "ResourceKey":"Network",
            "Form":"CONSTANT"
        },
        {
            "Value":"catalog-system/vpc-bp1ohdo84u2lt9wzq****",
            "ResourceKey":"VPCNameAndId",
            "Form":"CONSTANT"
        },
        {
            "Value":"[\"eb/vsw-bp10rbrt6rb6vrd89****\"]",
            "ResourceKey":"VSwitchesNameAndId",
            "Form":"CONSTANT"
        },
        {
            "Value":"sg-catalog-eventlistener/sg-bp14zrnfyik5av27****",
            "ResourceKey":"SecurityGroupNameAndId",
            "Form":"CONSTANT"
        },
        {
            "Value":"",
            "ResourceKey":"Token",
            "Form":"CONSTANT"
        }
    ]
}

数据库

  • 当事件目标选择RDS For MySQL数据库时,元数据参数中的Type值为 acs.rds.mysqlEndpoint表示配置的URL地址,格式为acs:rds:${region}:${uid}:dbinstance/${dbinstanceid}ParamList中的resourceKey字段含义如下表所示。

    resourceKey

    是否必传

    form

    value

    template

    resourceKey

    是否必传

    form

    value

    template

    InstanceId

    CONSTANT

    实例ID。

    DBName

    CONSTANT

    数据库名称。

    AccountName

    CONSTANT

    数据库账号。

    AccountPassword

    CONSTANT

    数据库密码。

    ExecuteSQL

    • ORIGINAL

    • CONSTANT

    • JSONPATH

    • TEMPLATE

    自定义SQL。

    如果form选择TEMPLATE,则在此处配置模板。

    VpcId

    CONSTANT

    VPC ID。

    VSwitchIds

    CONSTANT

    虚拟交换机ID。

    SecurityGroupId

    CONSTANT

    安全组ID。

    JSONPath示例如下:

    {
        "Id":"BRTt1sNe3IvdvejN07k5Sb****",
        "Type":"acs.rds.mysql",
        "Endpoint":"acs:rds:cn-zhangjiakou:164901546557****:dbinstance/${dbinstanceid}",
        "ConcurrentConfig":{
            "Concurrency":10
        },
        "ParamList":[
            {
                "Value":"rm-8vban2a66q93o****",
                "ResourceKey":"InstanceId",
                "Form":"CONSTANT"
            },
            {
                "Value":"db-test",
                "ResourceKey":"DBName",
                "Form":"CONSTANT"
            },
            {
                "Value":"db_name",
                "ResourceKey":"AccountName",
                "Form":"CONSTANT"
            },
            {
                "Value":"Aliyun****",
                "ResourceKey":"AccountPassword",
                "Form":"CONSTANT"
            },
            {
                "Value":"{\n    \"tableName\": \"customer\",\n    \"column1\": \"$.data.tableName\",\n    \"column1_value\": \"$.data.id\"\n}",
                "Template":"INSERT INTO ${tableName} \n (${column1}) VALUES('${column1_value}')",
                "ResourceKey":"ExecuteSQL",
                "Form":"TEMPLATE"
            },
            {
                "Value":"vpc-8vbeokru8z8erie8e****",
                "ResourceKey":"VpcId",
                "Form":"CONSTANT"
            },
            {
                "Value":"vsw-8vb9alm00nf29ijxt****",
                "ResourceKey":"VSwitchIds",
                "Form":"CONSTANT"
            }
            {
                "Value":"sg-8vbb59f5vq1ydiwr****",
                "ResourceKey":"SecurityGroupId",
                "Form":"CONSTANT"
            }
        ]
    }
  • 当事件目标选择自建MySql数据库时,元数据参数中的Type值为 mysqlEndpoint配置格式为数据库地址${ConnectionStringAndPort}ParamList中的resourceKey字段含义如下表所示。

    resourceKey

    是否必传

    form

    value

    template

    resourceKey

    是否必传

    form

    value

    template

    ConnectionStringAndPort

    CONSTANT

    数据库地址。

    DBName

    CONSTANT

    数据库名称。

    AccountName

    CONSTANT

    数据库账号。

    AccountPassword

    CONSTANT

    数据库密码。

    ExecuteSQL

    • ORIGINAL

    • CONSTANT

    • JSONPATH

    • TEMPLATE

    自定义SQL。

    Network

    CONSTANT

    网络类型。取值如下:

    • PublicNetwork:公网。

    • PrivateNetwork:VPC网络,如果选择此项,需要配置VPC、vSwitchSecurityGroup信息。

    VpcId

    否,当Network取值为PrivateNetwork时必传。

    CONSTANT

    VPC ID。

    VSwitchIds

    否,当Network取值为PrivateNetwork时必传。

    CONSTANT

    虚拟交换机ID。

    SecurityGroupId

    否,当Network取值为PrivateNetwork时必传。

    CONSTANT

    安全组ID。

    示例一:网络配置公网

    {
        "Id":"HmfVOvdG4k1NK9qJiqrxtv****",
        "Type":"mysql",
        "Endpoint":"192.168.XX.XX:3306",
        "ConcurrentConfig":{
            "Concurrency":10
        },
        "ParamList":[
            {
                "Value":"192.168.XX.XX:3306",
                "ResourceKey":"ConnectionStringAndPort",
                "Form":"CONSTANT"
            },
            {
                "Value":"db-test",
                "ResourceKey":"DBName",
                "Form":"CONSTANT"
            },
            {
                "Value":"dbTest",
                "ResourceKey":"AccountName",
                "Form":"CONSTANT"
            },
            {
                "Value":"Mydb****",
                "ResourceKey":"AccountPassword",
                "Form":"CONSTANT"
            },
            {
                "Value":"{\n    \"tableName\": \"user\",\n    \"column1\": \"$.data.tableName\",\n    \"column1_value\": \"$.data.id\"\n}",
                "Template":"INSERT INTO ${tableName} \n (${column1}) VALUES('${column1_value}')",
                "ResourceKey":"ExecuteSQL",
                "Form":"TEMPLATE"
            },
        ]
    }

    示例二:网络配置专有网络VPC

    {
        "Id":"HmfVOvdG4k1NK9qJiqrxtv****",
        "Type":"mysql",
        "Endpoint":"192.168.XX.XX:3306",
        "ConcurrentConfig":{
            "Concurrency":10
        },
        "ParamList":[
            {
                "Value":"vpc-8vbeokru8z8erie8e****",
                "ResourceKey":"VpcId",
                "Form":"CONSTANT"
            },
            {
                "Value":"vsw-8vbo9jk84z0obm24f****",
                "ResourceKey":"VSwitchIds",
                "Form":"CONSTANT"
            },
            {
                "Value":"192.168.XX.XX:3306",
                "ResourceKey":"ConnectionStringAndPorte",
                "Form":"CONSTANT"
            },
            {
                "Value":"my-db",
                "ResourceKey":"DBName",
                "Form":"CONSTANT"
            },
            {
                "Value":"dmsTest",
                "ResourceKey":"AccountName",
                "Form":"TEMPLATE"
            },
            {
                "Value":"Mydb****",
                "ResourceKey":"AccountPassword",
                "Form":"CONSTANT"
            },
            {
                "Value":"{\n    \"tableName\": \"user\",\n    \"column1\": \"$.data.tableName\",\n    \"column1_value\": \"$.data.id\"\n}",
                "Template": "INSERT INTO ${tableName} \n (${column1}) VALUES('${column1_value}')",
                "ResourceKey":"ExecuteSQL",
                "Form":"TEMPLATE"
            }
        ]
    }

事件总线EventBridge

当事件目标选择为事件总线EventBridge时,元数据参数中的Typeacs.eventbridgeEndpoint格式为acs:eventbridge:${region}:${AccountId}:eventbus/${EventBusName}ParamList中的resourceKey字段含义如下表所示。

resourceKey

是否必传

form

value

template

resourceKey

是否必传

form

value

template

RegionId

CONSTANT

投递的目标地域ID。

AccountType

CONSTANT

账号类型,取值如下:

  • AnotherAccount:其它阿里云账户。

  • SameAccount:当前阿里云账户。

AccountId

否,默认为当前账号。

CONSTANT

写入目标账号ID;如果AccountTypeSameAccount,可不填写此参数。

EventBusName

CONSTANT

写入目标总线的名称。

RAMRoleName

否,跨账号投递时必传。

CONSTANT

授予的角色名称。详细信息,请参见路由到事件总线EventBridge。如果AccountTypeSameAccount,可不填写此参数。

Body

ORIGINAL,表示投递完整事件。

无。

JSONPath示例如下:

示例一:写入当前账号的事件总线

{
    "Id":"KD20k9rpqDRXPq0SXXlqeT****",
    "Type":"acs.eventbridge",
    "Endpoint":"acs:eventbridge:cn-hangzhou:xxxxx:eventbus/xxxxx",
    "ParamList":[
        {
            "Value":"cn-hangzhou",
            "ResourceKey":"RegionId",
            "Form":"CONSTANT"
        },
        {
            "Value":"SameAccount",
            "ResourceKey":"AccountType",
            "Form":"CONSTANT"
        },
        {
            "Value":"xxxxx",
            "ResourceKey":"EventBusName",
            "Form":"CONSTANT"
        },
        {
            "ResourceKey":"Body",
            "Form":"ORIGINAL"
        }
    ]
}

示例二:写入其他账号的事件总线

{
    "Id":"KD20k9rpqDRXPq0SXXlqeT****",
    "Type":"acs.eventbridge",
    "Endpoint":"acs:eventbridge:cn-hangzhou:xxxxx:eventbus/xxxxx",
    "ParamList":[
        {
            "Value":"cn-hangzhou",
            "ResourceKey":"RegionId",
            "Form":"CONSTANT"
        },
        {
            "Value":"AnotherAccount",
            "ResourceKey":"AccountType",
            "Form":"CONSTANT"
        },
        {
            "Value":"xxxxx",
            "ResourceKey":"AccountId",
            "Form":"CONSTANT"
        },
        {
            "Value":"xxxxx",
            "ResourceKey":"EventBusName",
            "Form":"CONSTANT"
        },
        {
            "Value":"xxxxx",
            "ResourceKey":"RAMRoleName",
            "Form":"CONSTANT"
        },
        {
            "ResourceKey":"Body",
            "Form":"ORIGINAL"
        }
    ]
}

API触发

当事件目标选择为API端点时,元数据参数中的Typeacs.api.destinationEndpoint格式为acs:api-destination:${region}:${AccountId}:eventbus/${APIName}ParamList中的resourceKey字段含义如下表所示。

resourceKey

是否必传

form

value

template

resourceKey

是否必传

form

value

template

Name

CONSTANT

API端点名称

HeaderParameters

TEMPLATE

请求头参数

在此处配置模板。

BodyParameters

TEMPLATE

请求体参数

在此处配置模板。

QueryStringParameters

TEMPLATE

请求路径参数

在此处配置模板。

JSONPath示例如下:

{
    "id":"gwrxsJKAnLxSEo4GHhV69q****",
    "type":"acs.api.destination",
    "endpoint":"acs:api-destination:cn-hangzhou:11860954742****:name/api-key-test",
    "pushSelector":"PARAM_TRANSFORMER",
    "errorsTolerance":"ALL",
    "pushRetryStrategy":"BACKOFF_RETRY",
    "paramList":[
        {
            "resourceKey":"Name",
            "form":"CONSTANT",
            "value":"api-key-test"
        },
        {
            "resourceKey":"HeaderParameters",
            "form":"TEMPLATE",
            "value":"{\"headerKey1\":\"Content-Type\",\"headerValue1\":\"multipart/form-data\",\"headerKey2\":\"name\",\"headerValue2\":\"$.data.name\",\"headerKey3\":\"$.data.number\",\"headerValue3\":\"name\"}",
            "template":"{\"${headerKey1}\":\"${headerValue1}\",\"${headerKey2}\":\"${headerValue2}\",\"${headerKey3}\":\"${headerValue3}\"}"
        },
        {
            "resourceKey":"BodyParameters",
            "form":"TEMPLATE",
            "value":"{\"bodyKey1\":\"name\",\"bodyValue1\":\"$.data.name\"}",
            "template":"{\"${bodyKey1}\":\"${bodyValue1}\"}"
        },
        {
            "resourceKey":"QueryStringParameters",
            "form":"TEMPLATE",
            "value":"{\"queryKey1\":\"name\",\"queryValue1\":\"$.data.name\",\"queryKey2\":\"$.data.name\",\"queryValue2\":\"name\"}",
            "template":"{\"${queryKey1}\":\"${queryValue1}\",\"${queryKey2}\":\"${queryValue2}\"}"
        }
    ]
}

云工作流

当事件目标选择为云工作流(CloudFlow)时,元数据参数中的Typeacs.fnfEndpoint格式为acs:fnf:${region}:${AccountId}:flow/${flow}ParamList中的resourceKey字段含义如下表所示。

resourceKey

是否必传

form

value

template

resourceKey

是否必传

form

value

template

FlowName

CONSTANT

流程名称。

ExecutionName

  • JSONPATH

  • CONSTANT

  • TEMPLATE

执行名称。

事件转换的格式。共有以下四种类型:

  • ORIGINAL:完整事件。无需定义valuetemplate事件总线EventBridge不对事件进行转换,将原生CloudEvents的完整结构路由到事件目标。更多信息,请参见完整事件

  • JSONPATH:部分事件。无需定义template,只需定义value事件总线EventBridge通过JSONPathCloudEvents中提取事件中的参数,将指定的事件内容路由到事件目标。更多信息,请参见部分事件

    value示例值如下所示。

    $.data.name
  • CONSTANT:常量。无需定义template,只需定义value。无论事件内容是什么,事件总线EventBridge只把value定义的常量路由到事件目标。更多信息,请参见常量

    value示例值如下所示。

    "test1"
  • TEMPLATE:模板。需定义valuetemplate事件总线EventBridge通过JSONPathCloudEvents提取事件中的参数,把参数值存放在value中,然后按照template定义的格式路由到事件目标。更多信息,请参见模板

    value示例值如下所示。

    {
        "name":"$.data.name",
        "constant":"Please deal with it timely."
    }

    template示例值如下所示。

    The instance is broken,which name is ${name} , ${constant}

Input

JSONPATH

执行输入信息。

请参见ExecutionNameTEMPLATE。

RoleName

CONSTANT

角色配置。

JSONPath示例如下:

{
    "id":"KLUGLVJeuWDw1bIJ6lgURl****",
    "type":"acs.fnf",
    "endpoint":"acs:fnf:cn-hangzhou:118609547428****:flow/${flow}",
    "pushSelector":"PARAM_TRANSFORMER",
    "errorsTolerance":"ALL",
    "pushRetryStrategy":"BACKOFF_RETRY",
    "paramList":[
        {
            "value":"serverless",
            "resourceKey":"FlowName",
            "form":"CONSTANT"
        },
        {
            "value":"$.data",
            "resourceKey":"ExecutionName",
            "form":"JSONPATH"
        },
        {
            "value":"$.data",
            "resourceKey":"Input",
            "form":"JSONPATH"
        },
        {
            "value":"AliyunEventBridgeFNF-FZwEeE****",
            "resourceKey":"RoleName",
            "form":"CONSTANT"
        }
    ]
}

容器服务Kubernetes

当事件目标选择为容器服务 Kubernetes 版时,元数据参数中的Typeacs.k8sEndpoint值为kubernetesParamList中的resourceKey字段含义如下表所示。

resourceKey

是否必传

form

value

template

resourceKey

是否必传

form

value

template

KubeConfig

CONSTANT

集群配置文件。

YamlContent

CONSTANT

Yaml配置。

事件转换的格式。共有以下四种类型:

  • ORIGINAL:完整事件。无需定义valuetemplate事件总线EventBridge不对事件进行转换,将原生CloudEvents的完整结构路由到事件目标。更多信息,请参见完整事件

  • JSONPATH:部分事件。无需定义template,只需定义value事件总线EventBridge通过JSONPathCloudEvents中提取事件中的参数,将指定的事件内容路由到事件目标。更多信息,请参见部分事件

    value示例值如下所示。

    $.data.name
  • CONSTANT:常量。无需定义template,只需定义value。无论事件内容是什么,事件总线EventBridge只把value定义的常量路由到事件目标。更多信息,请参见常量

    value示例值如下所示。

    "test1"
  • TEMPLATE:模板。需定义valuetemplate事件总线EventBridge通过JSONPathCloudEvents提取事件中的参数,把参数值存放在value中,然后按照template定义的格式路由到事件目标。更多信息,请参见模板

    value示例值如下所示。

    {
        "name":"$.data.name",
        "constant":"Please deal with it timely."
    }

    template示例值如下所示。

    The instance is broken,which name is ${name} , ${constant}

Network

CONSTANT

网络访问。

QPSLimit

CONSTANT

限流配置。

JSONPath示例如下:

{
    "id":"Grdzk1cR4DNjmHa0oPJp8j****",
    "type":"acs.k8s",
    "endpoint":"kubernetes",
    "pushSelector":"PARAM_TRANSFORMER",
    "errorsTolerance":"ALL",
    "pushRetryStrategy":"BACKOFF_RETRY",
    "paramList":[
        {
            "form":"CONSTANT",
            "value":"PublicNetwork",
            "resourceKey":"Network"
        },
        {
            "form":"CONSTANT",
            "value":5,
            "resourceKey":"QPSLimit"
        },
        {
            "form":"CONSTANT",
            "value":"test1",
            "resourceKey":"KubeConfig"
        },
        {
            "form":"CONSTANT",
            "resourceKey":"YamlContent",
            "value":"test2"
        }
    ]
}

Serverless应用引擎

当事件目标选择为Serverless 应用引擎时,元数据参数中的Typeacs.saeEndpoint格式为http://sae.cn-huhehaote.aliyuncs.com/pop/v1/sam/job/execJobParamList中的resourceKey字段含义如下表所示。

resourceKey

是否必传

form

value

template

resourceKey

是否必传

form

value

template

RegionId

CONSTANT

地域ID。

事件转换的格式。共有以下四种类型:

  • ORIGINAL:完整事件。无需定义valuetemplate事件总线EventBridge不对事件进行转换,将原生CloudEvents的完整结构路由到事件目标。更多信息,请参见完整事件

  • JSONPATH:部分事件。无需定义template,只需定义value事件总线EventBridge通过JSONPathCloudEvents中提取事件中的参数,将指定的事件内容路由到事件目标。更多信息,请参见部分事件

    value示例值如下所示。

    $.data.name
  • CONSTANT:常量。无需定义template,只需定义value。无论事件内容是什么,事件总线EventBridge只把value定义的常量路由到事件目标。更多信息,请参见常量

    value示例值如下所示。

    "test1"
  • TEMPLATE:模板。需定义valuetemplate事件总线EventBridge通过JSONPathCloudEvents提取事件中的参数,把参数值存放在value中,然后按照template定义的格式路由到事件目标。更多信息,请参见模板

    value示例值如下所示。

    {
        "name":"$.data.name",
        "constant":"Please deal with it timely."
    }

    template示例值如下所示。

    The instance is broken,which name is ${name} , ${constant}

AppId

CONSTANT

任务模板ID。

请参见RegionIdtemplate。

EventId

JSONPATH

事件ID。

请参见RegionIdtemplate。

Parameters

CONSTANT

execjobCommandArgs Envs参数。

请参见RegionIdtemplate。

JSONPath示例如下:

{
    "id":"xp0dEW4mVbS5tDQzIBiZrY****",
    "type":"acs.sae",
    "endpoint":"http://sae.cn-huhehaote.aliyuncs.com/pop/v1/sam/job/execJob",
    "pushSelector":"PARAM_TRANSFORMER",
    "errorsTolerance":"ALL",
    "pushRetryStrategy":"BACKOFF_RETRY",
    "paramList":[
        {
            "value":"cn-huhehaote",
            "resourceKey":"RegionId",
            "form":"CONSTANT"
        },
        {
            "value":"3F2504E0-4F89-11D3-9A0C-0305E82C****",
            "resourceKey":"AppId",
            "form":"CONSTANT"
        },
        {
            "value":"$.id",
            "resourceKey":"EventId",
            "form":"JSONPATH"
        },
        {
            "value":"[\"a\",\"b\"]",
            "resourceKey":"Parameters",
            "form":"CONSTANT"
        }
    ]
}

事件分析EventBridge

当事件目标选择为事件分析EventBridge时,元数据参数中的Typeacs.eventbridge.olapEndpoint格式为${SchemaURI}ParamList中的resourceKey字段含义如下表所示。

resourceKey

是否必传

form

value

template

resourceKey

是否必传

form

value

template

UseSchema

CONSTANT

绑定映射方式。取值如下:

  • FromEvent: 使用事件的dataschema字段中指定的schema。

  • FromRule: 使用规则中指定的schema。

SchemaGroup

CONSTANT

Group名称。

SchemaID

CONSTANT

Schema标识。

SchemaVersion

CONSTANT

Schema版本。

JSONPath示例如下:

{
    "id":"DLuVyP3JcAAb3q2CibqZI6****",
    "type":"acs.eventbridge.olap",
    "endpoint":"${SchemaURI}",
    "pushSelector":"PARAM_TRANSFORMER",
    "errorsTolerance":"ALL",
    "pushRetryStrategy":"BACKOFF_RETRY",
    "paramList":[
        {
            "value":"FromRule",
            "resourceKey":"UseSchema",
            "form":"CONSTANT"
        },
        {
            "value":"DEFAULT_SCHEMA_GROUP",
            "resourceKey":"SchemaGroup",
            "form":"CONSTANT"
        },
        {
            "value":"test",
            "resourceKey":"SchemaID",
            "form":"CONSTANT"
        },
        {
            "value":"1",
            "resourceKey":"SchemaVersion",
            "form":"CONSTANT"
        }
    ]
}

数据总线DataHub

当事件目标选择为数据总线 DataHub时,元数据参数中的Typeacs.datahubEndpoint格式为acs:datahub:${region}:${AccountId}:project/${project}/topic/${topic}ParamList中的resourceKey字段含义如下表所示。

resourceKey

是否必传

form

value

template

resourceKey

是否必传

form

value

template

Project

CONSTANT

项目名称。

Topic

CONSTANT

Topic名称。

TopicType

CONSTANT

Topic的数据类型。取值如下:

  • TUPLE:支持类似于数据库的记录的数据,每条记录包含多个列。

  • BLOB:仅支持写入一块二进制数据。

TopicSchema

TopicTypeTUPLE时,此参数必传。TopicTypeBLOB时,无需传递此参数。

TEMPLATE

TopicSchema。

TEMPLATE。示例值如下:

{
    "resourceKey":"TopicSchema",
    "value":"{\"k1-0\":\"a\",\"k2-1\":\"$.data.name\",\"k3-2\":\"v\"}",
    "form":"TEMPLATE",
    "template":"{\"k1\":\"${k1-0}\",\"k2\":\"${k2-1}\",\"k3\":\"${k3-2}\"}"
}

其中templateki(i=1,2,3,...)表示topici个字段,对应值为value中定义变量,可以填写部分事件或者常量 。

RoleName

CONSTANT

角色配置。

JSONPath示例如下:

{
    "id":"ZXoGuhjAT5UfqngBPapXro****",
    "type":"acs.datahub",
    "endpoint":"acs:datahub:cn-hangzhou:175299981560****:project/demo_project/topic/demo_topic",
    "errorsTolerance":"ALL",
    "pushRetryStrategy":"BACKOFF_RETRY",
    "paramList":[
        {
            "Form":"CONSTANT",
            "Value":"demo_project",
            "ResourceKey":"Project"
        },
        {
            "Form":"CONSTANT",
            "Value":"demo_topic",
            "ResourceKey":"Topic"
        },
        {
            "Form":"CONSTANT",
            "Value":"TUPLE",
            "ResourceKey":"TopicType"
        },
        {
            "Form":"TEMPLATE",
            "Value":"{\"k1-0\":\"1\",\"k2-1\":\"2\",\"k3-2\":\"3\"}",
            "Template":"{\"k1\":\"${k1-0}\",\"k2\":\"${k2-1}\",\"k3\":\"${k3-2}\"}",
            "ResourceKey":"TopicSchema"
        },
        {
            "Form":"CONSTANT",
            "Value":"AliyunEventBridgeDataHubRole-2HwuVf****",
            "ResourceKey":"RoleName"
        }
    ]
}
  • 本页导读 (1)
  • 请求参数
  • 返回参数
  • 钉钉
  • 邮箱
  • 短信
  • 函数计算
  • 轻量消息队列
  • 云消息队列 RocketMQ 版
  • 云消息队列 RabbitMQ 版
  • 云消息队列 Kafka 版
  • 日志服务SLS
  • HTTP/HTTPS
  • 数据库
  • 事件总线EventBridge
  • API触发
  • 云工作流
  • 容器服务Kubernetes
  • Serverless应用引擎
  • 事件分析EventBridge
  • 数据总线DataHub