| object | | |
Message | string | The error message that is returned if the request failed. | The event streaming [xxxx] not existed! |
RequestId | string | | 7892F480-58C9-5067-AB35-8A7BEF0F726A |
Data | object | | |
EventStreamingName | string | The name of the event stream that is returned. | rocketmq-sync |
Description | string | The description of the event stream that is returned. | RocketMQ-to-RocketMQ |
Source | object | The event provider, which is also known as the event source. | |
SourceMNSParameters | object | | |
RegionId | string | The region ID of the MNS queue. | cn-hangzhou |
QueueName | string | The name of the MNS queue. | demo |
IsBase64Decode | boolean | Indicates whether Base64 encoding is enabled. | true |
SourceRabbitMQParameters | object | Source RabbitMQ Parameters | |
RegionId | string | The region ID of the Message Queue for RabbitMQ instance. | cn-hangzhou |
InstanceId | string | The ID of the Message Queue for RabbitMQ instance. | i-f8z9a9mcgwri1c1idd0z |
VirtualHostName | string | The vhost name of the Message Queue for RabbitMQ instance. | eb-connect |
QueueName | string | The name of the queue in the Message Queue for RabbitMQ instance. | comp |
SourceRocketMQParameters | object | Source RocketMQ Parameters | |
RegionId | string | The region ID of the Message Queue for Apache RocketMQ instance. | cn-hangzhou |
InstanceId | string | The ID of the Message Queue for Apache RocketMQ instance. | i-f8zbher64dlm58plyfte |
Topic | string | The topic to which the message belongs. | topic_add_anima |
Tag | string | The tags that are used to filter messages. | v1 |
Offset | string | The consumer offset of messages. Valid values: CONSUME_FROM_LAST_OFFSET: Start consumption from the latest offset. CONSUME_FROM_FIRST_OFFSET: Start consumption from the earliest offset. CONSUME_FROM_TIMESTAMP: Start consumption from the offset at the specified point in time. | CONSUMEFROMLASTOFFSET |
GroupID | string | The ID of the consumer group in the Message Queue for Apache RocketMQ instance. | GID_group1 |
Timestamp | long | The timestamp of the offset from which consumption starts. This parameter is valid only if you set the Offset parameter to CONSUME_FROM_TIMESTAMP. | 1636597951964 |
SourceKafkaParameters | object | | |
RegionId | string | The region ID of the Message Queue for Apache Kafka instance. | cn-hangzhou |
InstanceId | string | | i-bp1fbtrnqmjvgq66ajdw |
Topic | string | | topic_empower_1642473600414 |
ConsumerGroup | string | The ID of the consumer group that subscribes to the topic. | GID_TEST |
OffsetReset | string | | latest |
Network | string | The network. Default value: Default. The value PublicNetwork specifies a virtual private cloud (VPC). | Default |
VpcId | string | The ID of the virtual private cloud (VPC). | vpc-2zehizpoendb3nwwu9w5o |
VSwitchIds | string | | vsw-wz9qqeovkwjxlu9uc8rst |
SecurityGroupId | string | | sg-2vcgdxz7o1n9zappuimt |
SourceMQTTParameters | object | The parameters that are returned if the event source is Message Queue for MQTT. | |
RegionId | string | The region ID of the Message Queue for MQTT instance. | cn-shanghai |
InstanceId | string | | i-2ze06wqdwk0uq14krrzv |
Topic | string | The name of the topic in the Message Queue for MQTT instance. | TOPIC-cainiao-pcs-wms-instock-noPrealertPrintLabel |
SourceDTSParameters | object | The parameters that are returned if the event source is Data Transmission Service (DTS). | |
TaskId | string | | f86e5814-b223-482c-b768-3b873297dade |
BrokerUrl | string | The URL and port number of the data subscription channel. | |
Topic | string | The topic to which you want to subscribe by using the data subscription channel. | TP_TEST_UNDERWRITE_ISSUE |
Sid | string | The ID of the consumer group. | HD1 |
Username | string | The account of the consumer group. | admin |
Password | string | The password of the consumer group. | admin |
InitCheckPoint | string | The consumer offset. A consumer offset is a timestamp that indicates when the SDK client consumes the first data record. The value is a UNIX timestamp. | 1620962769 |
SourceSLSParameters | object | The parameters that are returned if the event provider is Simple Log Service. | |
Project | string | | dmmzk |
LogStore | string | The Log Service Logstore. | waf-logstore |
ConsumerGroup | string | | |
ConsumePosition | string | The starting consumer offset. The value begin indicates the earliest offset, and the value end indicates the latest offset. You can also specify a time in seconds to start consumption. | begin |
RoleName | string | The role name. If you want to authorize EventBridge to use this role to read logs in Log Service, you must select Alibaba Cloud Service for Selected Trusted Entity and EventBridge for Select Trusted Service when you create the role in the RAM console. | testRole |
FilterPattern | string | The rule that is used to filter events. If you leave this parameter empty, all events are matched. | |
Sink | object | | |
SinkMNSParameters | object | The parameters that are returned if the event target is Message Service (MNS). | |
QueueName | object | The target service type is MNS. | |
Value | string | The name of the MNS queue. | MyQueue |
Form | string | The method that is used to transform the event. Default value: CONSTANT. | CONSTANT |
Template | string | | |
Body | object | | |
Value | string | The value before the transformation. | {
"key": "value"
} |
Form | string | The method that is used to transform the event. | TEMPLATE |
Template | string | The template based on which the event is transformed. | The value of ${key} is ${value}! |
IsBase64Encode | object | Indicates whether Base64 encoding is enabled. | |
Value | string | Specifies that Base64 encoding is enabled. | true |
Form | string | The method that is used to transform the event. Default value: CONSTANT. | CONSTANT |
Template | string | | |
SinkRabbitMQParameters | object | The parameters that are returned if the event target is Message Queue for RabbitMQ. | |
InstanceId | object | The target service type is Message Queue for RabbitMQ instance. | |
Value | string | The ID of the Message Queue for RabbitMQ instance. | e5c9b727-e06c-4d7e-84d5-f8ce644e00bf |
Form | string | The method that is used to transform the event. Default value: CONSTANT. | CONSTANT |
Template | string | | |
VirtualHostName | object | The name of the vhost of the Message Queue for RabbitMQ instance. | |
Value | string | The vhost name of the Message Queue for RabbitMQ instance. | rabbit-host
|
Form | string | The method that is used to transform the event. Default value: CONSTANT. | CONSTANT |
Template | string | | |
TargetType | object | | |
Value | string | The type of the resource to which the event is delivered. Valid values: Exchange: exchanges. Queue: queues. | Exchange/Queue |
Form | string | The method that is used to transform the event. Default value: CONSTANT. | CONSTANT |
Template | string | | |
Exchange | object | The exchange mode. This parameter is available only if TargetType is set to Exchange. | |
Value | string | The name of the exchange in the Message Queue for RabbitMQ instance. | a_exchange |
Form | string | The method that is used to transform the event. Default value: CONSTANT. | CONSTANT |
Template | string | | |
RoutingKey | object | The routing rule for the message. This parameter is available only if TargetType is set to Exchange. | |
Value | string | The routing rule for the message. | housekeeping |
Form | string | The method that is used to transform the event. Default value: CONSTANT. | CONSTANT |
Template | string | | |
QueueName | object | The queue mode. This parameter is available only if TargetType is set to Queue. | |
Value | string | The name of the queue in the Message Queue for RabbitMQ instance. | MyQueue |
Form | string | The method that is used to transform the event. Default value: CONSTANT. | CONSTANT |
Template | string | | |
Body | object | | |
Value | string | The value before the transformation. | {
"key": "value"
} |
Form | string | The method that is used to transform the event. | TEMPLATE |
Template | string | The template based on which the event is transformed. | The value of ${key} is ${value}! |
MessageId | object | | |
Value | string | The value before the transformation. | {
"key": "value"
} |
Form | string | The method that is used to transform the event. | TEMPLATE |
Template | string | The template based on which the event is transformed. | The value of ${key} is ${value}! |
Properties | object | The tags that are used to filter messages. | |
Value | string | The value before the transformation. | {
"key": "value"
} |
Form | string | The method that is used to transform the event. | TEMPLATE |
Template | string | The template based on which the event is transformed. | The value of ${key} is ${value}!
|
SinkFcParameters | object | The parameters that are returned if the event target is Function Compute. | |
ServiceName | object | | |
Value | string | | myService |
Form | string | The method that is used to transform the event. Default value: CONSTANT. | CONSTANT |
Template | string | | |
FunctionName | object | | |
Value | string | | mFunction |
Form | string | The method that is used to transform the event. Default value: CONSTANT. | CONSTANT |
Template | string | | |
Concurrency | object | The delivery concurrency. Minimum value: 1. | |
Value | string | The delivery concurrency. Minimum value: 1. | 1 |
Form | string | The method that is used to transform the event. Default value: CONSTANT. | CONSTANT |
Template | string | | None
|
Qualifier | object | The alias of the service to which the function belongs. | |
Value | string | The alias of the service to which the function belongs. | LATEST |
Form | string | The method that is used to transform the event. Default value: CONSTANT. | CONSTANT |
Template | string | | |
InvocationType | object | The invocation type. Valid values: Sync: synchronous Async: asynchronous | |
Value | string | | Async |
Form | string | The method that is used to transform the event. Default value: CONSTANT. | CONSTANT |
Template | string | | |
Body | object | The message body that is sent to the function. | |
Value | string | The value before the transformation. | {
"key": "value"
} |
Form | string | The method that is used to transform the event. | TEMPLATE |
Template | string | The template based on which the event is transformed. | The value of ${key} is ${value}!
|
SinkKafkaParameters | object | The parameters that are returned if the event target is Message Queue for Apache Kafka. | |
InstanceId | object | The target service type is Message Queue for Apache Kafka. | |
Value | string | | Defaut_1283278472_sadkj |
Form | string | The method that is used to transform the event. Default value: CONSTANT. | CONSTANT |
Template | string | | |
Topic | object | | |
Value | string | | topic-test |
Form | string | The method that is used to transform the event. Default value: CONSTANT. | CONSTANT |
Template | string | | |
Acks | object | The acknowledgment information. | |
Value | string | The acknowledgment information. | 1 |
Form | string | The method that is used to transform the event. Default value: CONSTANT. | CONSTANT |
Template | string | | |
Key | object | | |
Value | string | | key |
Form | string | The method that is used to transform the event. Default value: CONSTANT. | CONSTANT |
Template | string | | |
Value | object | | |
Value | string | The value before the transformation. | {
"key": "value"
} |
Form | string | The method that is used to transform the event. | TEMPLATE |
Template | string | The template based on which the event is transformed. | The value of ${key} is ${value}!
|
SinkRocketMQParameters | object | | |
InstanceId | object | The target service type is Message Queue for Apache RocketMQ. | |
Value | string | The ID of the Message Queue for Apache RocketMQ instance. | MQ_INST_164901546557****_BAAN**** |
Form | string | The method that is used to transform the event. Default value: CONSTANT. | CONSTANT |
Template | string | | |
Topic | object | The name of the topic in the Message Queue for Apache RocketMQ instance. | |
Value | string | The name of the topic in the Message Queue for Apache RocketMQ instance. | Mytopic |
Form | string | The method that is used to transform the event. Default value: CONSTANT. | CONSTANT |
Template | string | | |
Body | object | | |
Value | string | The value before the transformation. | {
"key": "value"
} |
Form | string | The method that is used to transform the event. | TEMPLATE |
Template | string | The template based on which the event is transformed. | The value of ${key} is ${value}!
|
Properties | object | The tags that are used to filter messages. | |
Value | string | The value before the transformation. | {
"key": "value"
} |
Form | string | The method that is used to transform the event. | TEMPLATE |
Template | string | The template based on which the event is transformed. | The value of ${key} is ${value}!
|
Keys | object | The tags that are used to filter messages. | |
Value | string | The value before the transformation. | {
"key": "value"
} |
Form | string | The method that is used to transform the event. | TEMPLATE |
Template | string | The template based on which the event is transformed. | The value of ${key} is ${value}! |
Tags | object | The tags that are used to filter messages. | |
Value | string | The value before the transformation. | {
"key": "value"
} |
Form | string | The method that is used to transform the event. | TEMPLATE |
Template | string | The template based on which the event is transformed. | The value of ${key} is ${value}! |
SinkSLSParameters | object | | |
Project | object | The Simple Log Service project. | |
Value | string | | test-project
|
Form | string | The method that is used to transform the event. Default value: CONSTANT. | CONSTANT |
Template | string | | |
LogStore | object | The Simple Log Service Logstore. | |
Value | string | The Log Service Logstore. | test-logstore |
Form | string | The method that is used to transform the event. Default value: CONSTANT. | CONSTANT |
Template | string | | |
Topic | object | The name of the topic in which logs are stored. The topic corresponds to the topic reserved field in Simple Log Service. | |
Value | string | The name of the topic in which logs are stored. The topic corresponds to the topic reserved field in Log Service. | testTopic |
Form | string | The method that is used to transform the event. Default value: CONSTANT. | CONSTANT |
Template | string | | |
Body | object | | |
Value | string | The value before the transformation. | {
"key": "value"
} |
Form | string | The method that is used to transform the event. | TEMPLATE |
Template | string | The template based on which the event is transformed. | The value of ${key} is ${value}!
|
RoleName | object | The role name. If you want to authorize EventBridge to use this role to read logs in Simple Log Service, you must select Alibaba Cloud Service for Selected Trusted Entity and EventBridge for Select Trusted Service when you create the role in the Resource Access Management (RAM) console. | |
Value | string | The role name. If you want to authorize EventBridge to use this role to read logs in Log Service, you must select Alibaba Cloud Service for Selected Trusted Entity and EventBridge for Select Trusted Service when you create the role in the RAM console. | testRole |
Form | string | The method that is used to transform the event. Default value: CONSTANT. | CONSTANT |
Template | string | | |
SinkFnfParameters | object | | |
FlowName | object | | |
Value | string | | test-streaming-fnf |
Form | string | The method that is used to transform events. Default value: CONSTANT. | CONSTANT |
Template | string | | None
|
ExecutionName | object | | |
Value | string | | 123 |
Form | string | The method that is used to transform events. Default value: CONSTANT. | CONSTANT |
Template | string | | None
|
Input | object | The execution input information. | |
Value | string | The execution input information. | 123 |
Form | string | The method that is used to transform events. Default value: CONSTANT. | CONSTANT |
Template | string | | None
|
RoleName | object | | |
Value | string | | Al****FNF-x**** |
Form | string | The method that is used to transform events. Default value: CONSTANT. | CONSTANT |
Template | string | | None
|
RunOptions | object | The parameters that are configured for the runtime environment. | |
MaximumTasks | integer | | 2 |
RetryStrategy | object | The information about the retry policy that is used if the event fails to be pushed. | |
PushRetryStrategy | string | The retry policy. Valid values: BACKOFFRETRY and EXPONENTIALDECAY_RETRY. | BACKOFFRETRY |
MaximumEventAgeInSeconds | float | The maximum period of time during which retries are performed. | 512 |
MaximumRetryAttempts | float | The maximum number of retries. | 2 |
ErrorsTolerance | string | The fault tolerance policy. The value NONE specifies that faults are not tolerated, and the value All specifies that all faults are tolerated. | ALL |
DeadLetterQueue | object | Indicates whether dead-letter queues are enabled. By default, dead-letter queues are disabled. Messages that fail to be pushed after allowed retries as specified by the retry policy are discarded. | |
Arn | string | The Alibaba Cloud Resource Name (ARN) of the dead-letter queue. | acs:ram::1550203943326350:role/edskmstoecs |
BatchWindow | object | | |
CountBasedWindow | integer | The maximum number of events that are allowed in the batch window. If this threshold is reached, data in the window is pushed downstream. When multiple batch windows exist, data is pushed if triggering conditions are met in one of the windows. | 100 |
TimeBasedWindow | integer | The maximum period of time during which events are allowed in the batch window. Unit: seconds. If this threshold is reached, data in the window is pushed downstream. When multiple batch windows exist, data is pushed if triggering conditions are met in one of the windows. | 10 |
Status | string | The status of the event stream that is returned. | RUNNING |
Code | string | The response code. The value Success indicates that the request is successful. Other values indicate that the request failed. For a list of error codes, see Error codes. | Success |
Success | boolean | Indicates whether the operation is successful. The value true indicates that the operation is successful. | true |