Retrieve event stream details with GetEventStreaming - EventBridge - Alibaba Cloud - EventBridge

Retrieves the details of an event stream.

Operation description

Retrieves the details of an event stream.

Try it now

Try this API in OpenAPI Explorer, no manual signing needed. Successful calls auto-generate SDK code matching your parameters. Download it with built-in credential security for local usage.

Test

RAM authorization

The table below describes the authorization required to call this API. You can define it in a Resource Access Management (RAM) policy. The table's columns are detailed below:

Action: The actions can be used in the Action element of RAM permission policy statements to grant permissions to perform the operation.
API: The API that you can call to perform the action.
Access level: The predefined level of access granted for each API. Valid values: create, list, get, update, and delete.
Resource type: The type of the resource that supports authorization to perform the action. It indicates if the action supports resource-level permission. The specified resource must be compatible with the action. Otherwise, the policy will be ineffective.
- For APIs with resource-level permissions, required resource types are marked with an asterisk (*). Specify the corresponding Alibaba Cloud Resource Name (ARN) in the Resource element of the policy.
- For APIs without resource-level permissions, it is shown as All Resources. Use an asterisk (*) in the Resource element of the policy.
Condition key: The condition keys defined by the service. The key allows for granular control, applying to either actions alone or actions associated with specific resources. In addition to service-specific condition keys, Alibaba Cloud provides a set of common condition keys applicable across all RAM-supported services.
Dependent action: The dependent actions required to run the action. To complete the action, the RAM user or the RAM role must have the permissions to perform all dependent actions.

Action

Access level

Resource type

Condition key

Dependent action

eventbridge:GetEventStreaming

get

*EventStreaming

acs:eventbridge:{#regionId}:{#accountId}:eventstreaming/{#EventStreamingName}

None

Request parameters

Parameter	Type	Required	Description	Example
EventStreamingName	string	Yes	The name of the event stream that you want to query.	myeventstreaming

Response elements

Element	Type	Description	Example
	object	The response parameters.
Code	string	The response code. Valid values: Success: The request was successful. Other values: An error occurred. For more information, see error codes.	Success
Data	object	The returned data.
Description	string	The description of the event stream.	RocketMQ-to-RocketMQ
DetailedStatus	object	The detailed status.
DelayTime	integer	The delay time.	3
DiffOffset	integer	The difference offset.	0
Extensions	object	The extended properties.	{ "test": "test", "test2": 1 }
TPS	number	The number of transactions processed per second.	5
EventStreamingName	string	The name of the event stream.	rocketmq-sync
FilterPattern	string	The event filtering rule. If not specified, all events are matched.
Metadata	string
RunOptions	object	The runtime parameters.
BatchWindow	object	The batch window.
CountBasedWindow	integer	The maximum number of events that the window can contain. When this threshold is reached, data in the window is pushed downstream. If multiple windows exist, data is pushed when any window meets the threshold.	100
TimeBasedWindow	integer	The maximum time range (in seconds) of events that the window can contain. When this threshold is reached, data in the window is pushed downstream. If multiple windows exist, data is pushed when any window meets the threshold.	10
BusinessOption	object
BusinessMode	string
MaxCapacityUnitCount	integer
MinCapacityUnitCount	integer
DeadLetterQueue	object	Specifies whether to enable the dead-letter queue. The dead-letter queue is disabled by default. Messages that exceed the retry policy are discarded.
Arn	string	The ARN of the dead-letter queue.	acs:ram::155020394332****:role/edskmstoecs
Network	string	The network type of the dead-letter queue.	PrivateNetwork
SecurityGroupId	string	The security group ID of the instance where the dead-letter queue resides.	sg-2vcgdxz7o1n9zapp****
VSwitchIds	string	The vSwitch ID of the dead-letter queue.	vsw-m5ev8asdc6h12345****
VpcId	string	The VPC ID of the dead-letter queue.	vpc-2zehizpoendb3****
ErrorsTolerance	string	The fault tolerance policy. Valid values: NONE (no fault tolerance) and ALL (tolerate all exceptions).	ALL
MaximumTasks	integer	The concurrency.	2
RetryStrategy	object	The retry policy when event pushing fails.
MaximumEventAgeInSeconds	number	The maximum retry time.	512
MaximumRetryAttempts	number	The maximum number of retries.	2
PushRetryStrategy	string	The retry policy. Valid values: BACKOFF_RETRY (backoff retry) and EXPONENTIALDECAY_RETRY (exponential decay retry).	BACKOFF_RETRY
Throttling	integer
Sink	object	The event target.
SinkAgentRunParameters	SinkAgentRunParameters
SinkApacheKafkaParameters	object	The description.
Acks	string
Bootstraps	string
CompressionType	string
DynamicTopic	object	Specifies the target Topic routing strategy for messages. If both the topic parameter and the DynamicTopic parameter are specified, the DynamicTopic parameter takes precedence. Two configuration modes are supported: 1. Static constant mode: Directly specify a fixed Topic name string (for example, "order_created"). All messages are sent to this Topic. 2. Dynamic extraction mode: Specify a standard JSONPath expression (for example, "$.user.id" or "$.metadata.category"). The system parses the upstream message body and extracts the value of the matching field as the target Topic name.
Form	string	The transformation type. Valid values: CONSTANT: constant JSONPATH: extracts a value from the upstream source based on a path
Template	string	The template.
Value	string	The value.
Headers	object
Form	string
Template	string
Value	string
Key	object
Form	string
Template	string
Value	string
NetworkType	object
Form	string
Template	string
Value	string
SaslMechanism	string
SaslPassword	string
SaslUser	string
SecurityGroupId	object
Form	string
Template	string
Value	string
SecurityProtocol	string
SslKeyPassword	string	[Required for encrypted private keys] The Kafka client private key password. If the client private key is protected by password encryption (the PEM file contains the 'Proc-Type: 4,ENCRYPTED' or 'ENCRYPTED' marker), provide the decryption password. Leave this parameter empty if the private key is not encrypted. This password is used only to decrypt the private key and is not related to Kafka authentication.
SslKeystoreCertificateChain	string	[Required for mutual authentication] The Kafka client certificate chain. This parameter is required when the Kafka server enables mutual SSL authentication (ssl.client.auth=required). Format: Base64-encoded PEM format, containing the client certificate and the complete certificate chain (client certificate first, followed by intermediate CA certificates, with the root CA certificate being optional). Ensure that the content of each PEM file starts with '-----BEGIN CERTIFICATE-----' and ends with '-----END CERTIFICATE-----', and then Base64-encode the concatenated content.
SslKeystoreKey	object	[Required for bidirectional authentication] The SSL private key configuration object. When the Kafka server enables bidirectional SSL authentication, provide the client private key. Only KMS pattern is supported: specify the Key Management Service EPS resource that stores the private key by using KmsArn. The system retrieves the private key content from KMS only in memory, which provides higher security. Configuration example: {"KmsArn": "acs:kms:cn-hangzhou:123456789:secret/ssl-key-xxxx", "KmsSecretValueKey": "keystore_private_key"}
KmsArn	string	[Required] The KMS resource ARN that stores the SSL private key. Used to locate the Key Management Service instance that stores the client private key. Format example: 'acs:kms:cn-hangzhou:123456789:secret/ssl-keystore-key-xxxx'. You can view the ARN information of the corresponding key in the KMS console.
KmsSecretValueKey	string	[KMS KV mode] The key name in the KMS credential. If the KMS credential is stored in a key-value (KV) structure, specify this parameter to indicate the key that corresponds to the SSL private key. Example: if the KMS credential is '{"ssl_keystore_key":"-----BEGIN PRIVATE KEY-----...","ssl_truststore_key":"..."}', specify 'ssl_keystore_key'. If the KMS credential is in plain text mode (the PEM content of the private key is stored directly), leave this parameter empty.
SslTruststoreCertificates	string	[Required for SSL scenarios] The Kafka server trust certificate. Used to authenticate the legitimacy of the Kafka Broker SSL signing certificate and prevent man-in-the-middle attacks. Format: Base64 encoding of PEM format, typically containing the CA certificate of the Kafka server or the server certificate itself. Example: Base64-encode the PEM file content of the CA certificate (ensure it starts with '-----BEGIN CERTIFICATE-----' and ends with '-----END CERTIFICATE-----'). If Kafka uses a self-signed certificate, provide the CA certificate that issued the certificate.
Topic	string
VSwitchIds	object
Form	string
Template	string
Value	string
Value	object
Form	string
Template	string
Value	string
VpcId	object
Form	string
Template	string
Value	string
SinkApacheRocketMQCheckpointParameters	object	Sink Apache RocketMQ Checkpoint Parameters
ConsumeTimestamp	object	The timestamp of message consumption.
Form	string	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	The template style.
Value	string	The timestamp.	1570761026400
Group	object	The Group ID of the consumer group.
Form	string	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	The template style.
Value	string	Group ID	GID_EVENTBRIDGE_1736234******
InstanceEndpoint	string	The instance endpoint.	192.168.1.1:9876
InstancePassword	string	The password for authentication.	****
InstanceUsername	string	The username for authentication.	admin
NetworkType	string	The network type.	PrivateNetwork
SecurityGroupId	string	The security group ID.	sg-2ze5bmpw6adn0q******
Topic	object	The topic of the ApsaraMQ for RocketMQ instance.
Form	string	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	The template style.
Value	string	The name of the topic of the ApsaraMQ for RabbitMQ instance.	Mytopic
VSwitchId	string	The vSwitch ID.	vsw-uf62oqt1twuevrt******
VpcId	string	The VPC ID.	vpc-2zeccak5pb0j3ay******
SinkApiDestinationParameters	SinkApiDestinationParameters	The ApiDestination event target parameters.
SinkBaiLianParameters	SinkBaiLianParameters	Sink BaiLian Parameters
SinkCustomizedKafkaConnectorParameters	object	The Sink Kafka connector parameters.
ConnectorPackageUrl	string	The OSS file download URL.	"https://examplebucket.oss-cn-hangzhou.aliyuncs.com/testDoc/Old_Homebrew/2024-06-26%2022%3A34%3A08/opt/homebrew/homebrew/Library/Homebrew/test/support/fixtures/cask/AppWithBinary.zip?OSSAccessKeyId=ri&Expires=1725539627&Signature=rb8q3OpV******"
ConnectorParameters	object	The properties file parsed from the current ZIP package.
Config	object	The connector configuration.	{ "connector.class": "com.mongodb.kafka.connect.MongoSinkConnector", "tasks.max": "1", "topics": "sourceA,sourceB" }
Name	string	The connector name.	mongo-sink
WorkerParameters	object	The instance configuration.	{ "group.id": "connect-eb-cluster-KAFKA_CONNECTORC", "offset.storage.topic": "connect-eb-offset-KAFKA_CONNECTOR_yjqC8K5ewC", "config.storage.topic": "connect-eb-config-KAFKA_CONNECTOR_yjqC8K5ewC", "status.storage.topic": "connect-eb-status-KAFKA_CONNECTOR_yjqC8K5ewC", "consumer.group.id": "connector-eb-cluster-KAFKA_CONNECTOR_yjqC8K5ewC-mongo-sink", "bootstrap.servers": "alikafka-post:9092" }
SinkCustomizedKafkaParameters	object	The Sink Kafka parameters.
InstanceId	string	The instance ID of MSMQ for Apache Kafka.	90be1f96-4229-4535-bb76-34b4f6fb****
SinkDashVectorParameters	object	The Sink DashVector parameters.
ApiKey	string	The API key created in the DashVector console.	Q34nExQH7sQ****
Collection	string	The collection name.	collection1
DashVectorSchemaParameters	array<object>	The schema field definitions for table entries when inserting into DashVector. The result after event content transformation must be in JSON format.
	array<object>
Name	object
Form	string
Template	string
Value	string
Type	object
Form	string
Template	string
Value	string
Value	object
Form	string
Template	string
Value	string
InstanceId	string	The instance ID.	vrs-cn-lbj3ru1***
Network	string	The network type.	PublicNetwork
Operation	string	The operation type for the DashVector database.	Upsert
Partition	object	The partition. Default value: default.
Form	string	The transformation format.	CONSTANT
Template	string	None.
Value	string	If Form is set to CONSTANT: a constant value. If Form is set to JSONPATH: a JSONPath expression. Note: The Value field cannot exceed 10,240 characters.	default
PrimaryKeyId	object	The primary key ID used when inserting or deleting records. If this field is not specified, a random primary key ID is used.
Form	string	The transformation format.	JSONPATH
Template	string	The primary key ID template. This field is required only when Form is set to TEMPLATE.	${ID}
Value	string	If Form is set to JSONPATH: a JSONPath expression. If Form is set to TEMPLATE: a template variable. Note: The Value field cannot exceed 10,240 characters.	$.data.requestId
Vector	object	The vector of the DashVector record to insert.
Form	string	The transformation format.	JSONPATH
Template	string	None.
Value	string	The JSONPath expression. Note: The Value field cannot exceed 10,240 characters.	$.data.messageBody
SinkDataHubParameters	object	The Sink DataHub parameters.
Body	object	The record content template for the BLOB type.
Form	string	The transformation format.	ORIGINAL
Template	string	None.
Value	string	The record content template for the BLOB type.
Project	object	The DataHub project name.
Form	string	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	None.
Value	string	The DataHub project name.	demo-project
RoleName	object	The task role name.
Form	string	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	None.
Value	string	The task role name.	test-role
Topic	object	The DataHub topic name.
Form	string	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	None.
Value	string	The DataHub topic name.	demo-topic
TopicSchema	object	The topic content schema for the TUPLE type.
Form	string	The transformation format.	TEMPLATE
Template	string	The template style.	{"k1":"${k1}","k2":"${k2}"}
Value	string	The topic content schema for the TUPLE type.	{"k1":"value1","k2":"value2"}
TopicType	object	The topic type. Valid values: TUPLE BLOB
Form	string	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	None.
Value	string	The topic type. Valid values: TUPLE BLOB	TUPLE
SinkDataWorksTriggerParameters	SinkDataWorksTriggerParameters
SinkDorisParameters	object
BeHttpEndpoint	object
Form	string
Template	string
Value	string
Body	object
Form	string
Template	string
Value	string
Database	object
Form	string
Template	string
Value	string
FeHttpEndpoint	object
Form	string
Template	string
Value	string
NetworkType	object
Form	string
Template	string
Value	string
Password	object
Form	string
Template	string
Value	string
QueryEndpoint	object
Form	string
Template	string
Value	string
SecurityGroupId	object
Form	string
Template	string
Value	string
Table	object
Form	string
Template	string
Value	string
UserName	object
Form	string
Template	string
Value	string
VSwitchIds	object
Form	string
Template	string
Value	string
VpcId	object
Form	string
Template	string
Value	string
SinkFcParameters	object	The function target.
Body	object	The content body sent to the function.
Form	string	The transformation format. Valid values: ORIGINAL: complete event. JSONPATH: partial event. CONSTANT: constant. TEMPLATE: template. For more information, see Event transformation.	TEMPLATE
Template	string	The template style.	The value of ${key} is ${value}!
Value	string	The value before transformation.	{ "key": "value" }
Concurrency	object	The delivery concurrency. Minimum value: 1.
Form	string	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	The template style.	The value of ${key} is ${value}!
Value	string	The delivery concurrency. Minimum value: 1.	1
DataFormat	object	The format conversion rule for event content.
Form	string	The transformation format. Valid values: ORIGINAL: complete event. JSONPATH: partial event. CONSTANT: constant. TEMPLATE: template.	JSONPATH
Template	string	The template style.	$.data.key
Value	string	The value before transformation.	{ "key": "value" }
FunctionName	object	The function name.
Form	string	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	The template style.	The value of ${key} is ${value}!
Value	string	The function name.	mFunction
InvocationType	object	Specifies whether the invocation is synchronous or asynchronous. Valid values: Sync: Synchronous. Async: Asynchronous.
Form	string	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	The template style.	The value of ${key} is ${value}!
Value	string	Specifies whether the invocation is synchronous or asynchronous. Valid values: Sync: Synchronous. Async: Asynchronous.	Async
Qualifier	object	The service version.
Form	string	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	The template style.	The value of ${key} is ${value}!
Value	string	The service version.	LATEST
ServiceName	object	The service name.
Form	string	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	The template style.	The value of ${key} is ${value}!
Value	string	The service name.	myService
SinkFnfParameters	object	The Sink Fnf parameters.
ExecutionName	object	The execution name.
Form	string	The transformation format. Default value: CONSTANT. Valid values: JSONPATH: partial event. CONSTANT: constant. TEMPLATE: template. For more information, see Event transformation.	CONSTANT
Template	string	The template style.
Value	string	The execution name.	123
FlowName	object	The flow name.
Form	string	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	The template style.
Value	string	The flow name.	test-streaming-fnf
Input	object	The execution input information.
Form	string	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	The template style.
Value	string	The execution input information.	123
RoleName	object	The role configuration.
Form	string	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	The template style.
Value	string	The role configuration.	Al**FNF-x**
SinkHttpsParameters	SinkHttpsParameters	The HTTPS event target parameters.
SinkKafkaParameters	object	The Sink Kafka parameters.
Acks	object	The acknowledgment mode for writing to Kafka: acks=0: No response is required from the server. This mode offers high performance but a high risk of data loss. acks=1: A response is returned after the primary node on the server writes the data. This mode offers moderate performance and a moderate risk of data loss. Data loss may occur if the primary node goes down. acks=all: A response is returned only after the primary node writes the data and the secondary nodes complete synchronization. This mode offers lower performance but higher data safety. Data loss occurs only if both the primary and secondary nodes go down.
Form	string	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	The template style.	The value of ${key} is ${value}!
Value	string	The acknowledgment mode for writing to Kafka: acks=0: No response is required from the server. This mode offers high performance but a high risk of data loss. acks=1: A response is returned after the primary node on the server writes the data. This mode offers moderate performance and a moderate risk of data loss. Data loss may occur if the primary node goes down. acks=all: A response is returned only after the primary node writes the data and the secondary nodes complete synchronization. This mode offers lower performance but higher data safety. Data loss occurs only if both the primary and secondary nodes go down.	1
CompressionType	string
DynamicTopic	object	Specifies the target Topic routing strategy for messages. If both the topic parameter and the DynamicTopic parameter are specified, the DynamicTopic parameter takes precedence. Two configuration modes are supported: 1. Static constant mode: Directly specify a fixed Topic name string (for example, "order_created"). All messages are sent to this Topic. 2. Dynamic extraction mode: Specify a standard JSONPath expression (for example, "$.user.id" or "$.metadata.category"). The system parses the upstream message body and extracts the value of the matching field as the target Topic name.
Form	string	The transformation type. Valid values: CONSTANT: constant JSONPATH: extracts a value from the upstream source based on a path
Template	string	The template.
Value	string	The value.
Headers	object	The additional metadata of the Kafka message.
Form	string	The transformation format. Valid values: ORIGINAL: complete event. JSONPATH: partial event. CONSTANT: constant. TEMPLATE: template.	CONSTANT
Template	string	The template style.	The value of ${key} is ${value}!
Value	string	The value before transformation.	{ "key": "value" }
InstanceId	object	The event target service type is MSMQ for Apache Kafka.
Form	string	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	The template style.	The value of ${key} is ${value}!
Value	string	The instance ID.	Defaut_1283278472_s****
Key	object	The message key.
Form	string	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	The template style.	The value of ${key} is ${value}!
Value	string	The message key.	key
Topic	object	The topic name.
Form	string	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	The template style.	The value of ${key} is ${value}!
Value	string	The topic name.	test
Value	object	The message body.
Form	string	The transformation format.	TEMPLATE
Template	string	The template style.	The value of ${key} is ${value}!
Value	string	The value before transformation.	{ "key": "value" }
SinkKnowledgeBaseParameters	SinkKnowledgeBaseParameters	The event target parameters for delivering the event stream to an EventHouse knowledge base. This parameter is required only when the Sink type is set to knowledge base.
SinkMNSParameters	object	The MSMQ (formerly MNS) event target.
Body	object	The message content.
Form	string	The transformation format.	TEMPLATE
Template	string	The template style.	The value of ${key} is ${value}!
Value	string	The value before transformation.	{ "key": "value" }
IsBase64Encode	object	Specifies whether to enable Base64 encoding.
Form	string	The format of the event transformation. Default value: CONSTANT.	CONSTANT
Template	string	The template style.
Value	string	Enables Base64 encoding.	true
QueueName	object	The event target service type is MSMQ (formerly MNS).
Form	string	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	The template style.
Value	string	The name of the queue in MSMQ (formerly MNS).	MyQueue
SinkMQTTParameters	SinkMQTTParameters
SinkOSSParameters	SinkOSSParameters
SinkOpenSourceRabbitMQParameters	object	Sink Open Source RabbitMQ Parameters
AuthType	string	The authentication type.	ACL
Body	object	The message body content.
Form	string	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	The template style.	The value of ${key} is ${value}!
Value	string	The raw data value.	{"key": "value"}
Endpoint	string	The endpoint.	192.168.1.1:9876
Exchange	string	The Exchange name in RabbitMQ.	my-exchange
MessageId	object	The unique identifier of the message.
Form	string	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	The template style.
Value	string	The message ID value.	12345
NetworkType	string	The network type.	PublicNetwork
Password	string	The password for accessing the RabbitMQ instance.	****
Properties	object	The additional properties of the message.
Form	string	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	The template style.	The value of ${key} is ${value}!
Value	string	The property content.	{"env": "prod"}
QueueName	string	The queue name in RabbitMQ. This parameter takes effect only when TargetType is set to Queue.	my-queue
RoutingKey	object	The message routing key.
Form	string	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	The template style.	The value of ${key} is ${value}!
Value	string	The routing key value.	{"Form": "CONSTANT", "Value": "my-routing-key"}
SecurityGroupId	string	The security group ID.	sg-uf6of9452b2pba82c ****
TargetType	string	The target type for message delivery. This parameter takes effect only when TargetType is set to Exchange.	Exchange
Username	string	The username used to access the RabbitMQ instance.	admin
VSwitchIds	string	The vSwitch ID.	vsw-uf6of9452b2pba82c ****
VirtualHostName	string	The virtual host name of the RabbitMQ instance.	vhost1
VpcId	string	The VPC ID.	vpc-uf6of9452b2pba82c ****
SinkRabbitMQMetaParameters	SinkRabbitMQMetaParameters
SinkRabbitMQMsgSyncParameters	SinkRabbitMQMsgSyncParameters
SinkRabbitMQParameters	object	The parameters for the Sink RabbitMQ configuration.
Body	object	The message content.
Form	string	The transformation format.	TEMPLATE
Template	string	The template style.	The value of ${key} is ${value}!
Value	string	The value before transformation.	{ "key": "value" }
Exchange	object	The Exchange mode. This parameter is required only when TargetType is set to Exchange.
Form	string	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	The template style.	The value of ${key} is ${value}!
Value	string	The name of the Exchange in the ApsaraMQ for RabbitMQ instance.	a_exchange
InstanceId	object	The event target type is ApsaraMQ for RabbitMQ.
Form	string	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	The template style.	The value of ${key} is ${value}!
Value	string	The instance ID of the ApsaraMQ for RabbitMQ instance.	e5c9b727-e06c-4d7e-84d5-f8ce644e****
MessageId	object	The message ID.
Form	string	The transformation format.	TEMPLATE
Template	string	The template style.	The value of ${key} is ${value}!
Value	string	The value before transformation.	{ "key": "value" }
Properties	object	The filter properties.
Form	string	The transformation format.	TEMPLATE
Template	string	The template style.	The value of ${key} is ${value}!
Value	string	The value before transformation.	{ "key": "value" }
QueueName	object	The Queue mode. This parameter is required only when TargetType is set to Queue.
Form	string	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	The template style.	The value of ${key} is ${value}!
Value	string	The name of the Queue in the instance.	MyQueue
RoutingKey	object	The routing rule of the message. This parameter is required only when TargetType is set to Exchange.
Form	string	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	The template style.	The value of ${key} is ${value}!
Value	string	The routing rule of the message.	housekeeping
TargetType	object	The target type.
Form	string	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	The template style.	The value of ${key} is ${value}!
Value	string	The target type. Valid values: Exchange: Exchange mode. Queue: Queue mode.	Exchange/Queue
VirtualHostName	object	The name of the Vhost in the ApsaraMQ for RabbitMQ instance.
Form	string	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	The template style.
Value	string	The name of the Vhost in the ApsaraMQ for RabbitMQ instance.	rabbit-host
SinkRocketMQCheckpointParameters	object	Sink RocketMQ Checkpoint Parameters
ConsumeTimestamp	object	The timestamp of message consumption.
Form	string	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	The template style.
Value	string	The timestamp.	1570761026400
Group	object	The Group ID of the consumer group.
Form	string	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	The template style.
Value	string	Group ID	GID_EVENTBRIDGE_1736234******
InstanceId	string	The instance ID.	MQ_INST_164901546557**_BAAN**
InstanceType	string	The instance type. Valid values: Cloud_4: ApsaraMQ for RocketMQ 4.0 instance Cloud_5: ApsaraMQ for RocketMQ 5.0 instance	Cloud_4
Topic	object	The topic of the ApsaraMQ for RocketMQ instance.
Form	string	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	The template style.
Value	string	The topic name of the ApsaraMQ for RocketMQ instance.	Mytopic
SinkRocketMQParameters	object	Sink RocketMQ Parameters
Body	object	The message content.
Form	string	The transformation format.	TEMPLATE
Template	string	The template style.	The value of ${key} is ${value}!
Value	string	The value before transformation.	{ "key": "value" }
DeliveryOrderType	object	The delivery order type of the message. This parameter is optional. Default value: concurrent delivery.
Form	string	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	The template style.
Value	string	The delivery order type. Orderly: Ordered delivery. Concurrently: Concurrent delivery.	Concurrently
InstanceEndpoint	object	The instance endpoint.
Form	string	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	None.
Value	string	The instance endpoint.	vbr-8vbsvkkbpf3vb0zef****
InstanceId	object	The event target type is ApsaraMQ for RocketMQ.
Form	string	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	The template style.	The value of ${key} is ${value}!
Value	string	The instance ID of the ApsaraMQ for RocketMQ instance.	MQ_INST_164901546557**_BAAN**
InstancePassword	object	The instance password.
Form	string	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	None.
Value	string	The instance password.	admin****
InstanceType	object	The instance type. Valid values: Cloud_4: ApsaraMQ for RocketMQ 4.0 instance (default) Cloud_5: ApsaraMQ for RocketMQ 5.0 instance SelfBuilt: self-managed Apache RocketMQ cluster
Form	string	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	None.
Value	string	The instance type. Valid values: Cloud_4: ApsaraMQ for RocketMQ 4.0 instance (default) Cloud_5: ApsaraMQ for RocketMQ 5.0 instance SelfBuilt: self-managed Apache RocketMQ cluster	Cloud_4
InstanceUsername	object	The username of the instance.
Form	string	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	None.
Value	string	The username of the instance.	admin
Keys	object	The filter properties.
Form	string	The transformation format.	TEMPLATE
Template	string	The template style.	The value of ${key} is ${value}!
Value	string	The value before transformation.	{ "key": "value" }
Network	object	The network type. Valid values: PublicNetwork PrivateNetwork
Form	string	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	None.
Value	string	The network type. Valid values: PublicNetwork PrivateNetwork	PublicNetwork
Properties	object	The filter properties.
Form	string	The transformation format.	TEMPLATE
Template	string	The template style.	The value of ${key} is ${value}!
Value	string	The value before transformation.	{ "key": "value" }
SecurityGroupId	object	The security group ID.
Form	string	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	None.
Value	string	The security group ID.	b4bf375515f6440f942e3a20c33d****
ShardingKey	object	The sharding key of the message. Note ShardingKey is required when DeliveryOrderType is set to Orderly. When Source is set to RocketMQ, ShardingKey can be left empty. In this case, the upstream BrokerName and QueueId are concatenated to generate the message ShardingKey.
Form	string	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	The template style.
Value	string	The sharding key value.	order_id
Tags	object	The filter properties.
Form	string	The transformation format.	TEMPLATE
Template	string	The template style.	The value of ${key} is ${value}!
Value	string	The value before transformation.	{ "key": "value" }
Topic	object	The topic of the Message Queue for Apache RocketMQ instance.
Form	string	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	The template style.	The value of ${key} is ${value}!
Value	string	The name of the topic of the Message Queue for Apache RocketMQ instance.	Mytopic
VSwitchIds	object	The vSwitch ID.
Form	string	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	None.
Value	string	The vSwitch ID.	vbr-8vb835n3zf9shwl****mp
VpcId	object	The ID of the VPC.
Form	string	The format of the event transformation. Default value: CONSTANT.	CONSTANT
Template	string	None.
Value	string	The ID of the VPC.	vbr-8vb835n3zf9shwlvb****
SinkSLSParameters	object	Sink SLS Parameters
Body	object	The content sent to Simple Log Service (SLS).
Form	string	The transformation format.	TEMPLATE
Template	string	The template style.	The value of ${key} is ${value}!
Value	string	The value before transformation.	{ "key": "value" }
ContentSchema	object	The key-value pairs of the custom log. This parameter takes effect only when ContentType is set to KeyValue. Each key-value pair is represented by Key_n and Value_n.
Form	string	The template style.	CONSTANT
Template	string	The template style.
Value	string	The value before transformation.	{"Key_1":{"form":"CONSTANT","value":"demoKey"},"Value_1":{"form":"JSONPATH","value":"$.data.value"}}
ContentType	object	The data format of SLS. You can select the default format or configure specified key-value pairs. Valid values: JSON KeyValue
Form	string	The transformation format.	CONSTANT
Template	string	The template style.
Value	string	The value before transformation.	JSON
LogStore	object	The Logstore of Simple Log Service (SLS).
Form	string	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	The template style.
Value	string	The Logstore of Simple Log Service (SLS).	test-logstore
Project	object	The project of Simple Log Service (SLS).
Form	string	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	The template style.
Value	string	The project of Simple Log Service (SLS).	test-project
RoleName	object	The role that provides authorization for the event bus EventBridge to read SLS log content. When you create the role in the Resource Access Management (RAM) console, select "Alibaba Cloud Service" and set "Trusted Service" to "event bus".
Form	string	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	The template style.
Value	string	The role that provides authorization for the event bus EventBridge to read SLS log content. When you create the role in the Resource Access Management (RAM) console, select "Alibaba Cloud Service" and set "Trusted Service" to "event bus".	testRole
Topic	object	The topic where the log resides, corresponding to the SLS reserved field "topic".
Form	string	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	The template style.
Value	string	The topic where the log resides, corresponding to the SLS reserved field "topic".	testTopic
Source	object	The event source.
SourceApacheKafkaParameters	object
Bootstraps	string
ConsumerGroup	string
NetworkType	string
OffsetReset	string
SaslMechanism	string
SaslPassword	string
SaslUser	string
SecurityGroupId	string
SecurityProtocol	string
SslKeyPassword	string	[Required for encrypted private keys] The Kafka client private key password. If the client private key is protected by password encryption (the PEM file contains the 'Proc-Type: 4,ENCRYPTED' or 'ENCRYPTED' marker), provide the decryption password. Leave this parameter empty if the private key is not encrypted. This password is used only to decrypt the private key and is not related to Kafka authentication.
SslKeystoreCertificateChain	string	[Required for mutual authentication] The Kafka client certificate chain. This parameter is required when the Kafka server enables mutual SSL authentication (ssl.client.auth=required). Format: Base64-encoded PEM format, containing the client certificate and the complete certificate chain (client certificate first, followed by intermediate CA certificates, with the root CA certificate being optional). Ensure that the content of each PEM file starts with '-----BEGIN CERTIFICATE-----' and ends with '-----END CERTIFICATE-----', and then Base64-encode the concatenated content.
SslKeystoreKey	object	[Required for mutual authentication] The SSL private key configuration object. When the Kafka server enables mutual SSL authentication, the client private key must be provided. Only KMS mode is supported for the key: specify the Key Management Service resource that stores the private key by using KmsArn. The system retrieves the private key content from KMS only in memory, which provides higher security. Configuration example: {"KmsArn": "acs:kms:cn-hangzhou:123456789:secret/ssl-key-xxxx", "KmsSecretValueKey": "keystore_private_key"}
KmsArn	string	[Required] The KMS resource ARN that stores the SSL private key. Used to locate the Key Management Service instance that stores the client private key. Format example: 'acs:kms:cn-hangzhou:123456789:secret/ssl-keystore-key-xxxx'. You can view the ARN information of the corresponding key in the KMS console.
KmsSecretValueKey	string	[KMS KV mode] The key name in the KMS credential. If the KMS credential is stored in a key-value (KV) structure, specify this parameter to indicate the key that corresponds to the SSL private key. Example: if the KMS credential is '{"ssl_keystore_key":"-----BEGIN PRIVATE KEY-----...","ssl_truststore_key":"..."}', specify 'ssl_keystore_key'. If the KMS credential is in plain text mode (the PEM content of the private key is stored directly), leave this parameter empty.
SslTruststoreCertificates	string	[Required for SSL] The Kafka server truststore certificate. This certificate is used to authenticate the validity of the SSL certificate of the Kafka broker to prevent man-in-the-middle attacks. Format: Base64-encoded PEM format, which typically contains the CA certificate or the server certificate of the Kafka server. Example: Base64-encode the content of the CA certificate PEM file (make sure the content starts with '-----BEGIN CERTIFICATE-----' and ends with '-----END CERTIFICATE-----'). If Kafka uses a self-signed certificate, provide the CA certificate that issued the certificate.
Topic	string
VSwitchIds	string
ValueDataType	string
VpcId	string
SourceApacheRocketMQCheckpointParameters	object	The Source RocketMQ checkpoint parameters.
InstanceEndpoint	string	The instance endpoint.	registry-vpc.cn-hangzhou.aliyuncs.com
InstanceId	string	The instance ID of the RocketMQ instance.	MQ_INST_164901546557**_BAAN**
InstancePassword	string	The instance password.	123456
InstanceUsername	string	The username of the instance.	admin
NetworkType	string	The network type.	PrivateNetwork
RegionId	string	The region ID.	cn-hangzhou
SecurityGroupId	string	The security group ID.	sg-mw43*****
Topics	array	The list of topics.
	string	The list of topics to consume.	["Topic_1","Topic_2"]
VSwitchId	string	The vSwitch ID.	vsw-dwaafds****
VpcId	string	VPC ID。	vpc-adw1awdw*****
SourceCustomizedKafkaConnectorParameters	object	The custom connector Apache Kafka event source.
ConnectorPackageUrl	string	The download URL of the OSS resource ZIP package.	"https://examplebucket.oss-cn-hangzhou.aliyuncs.com/testDoc/Old_Homebrew/2024-06-26%2022%3A34%3A08/opt/homebrew/homebrew/Library/Homebrew/test/support/fixtures/cask/AppWithBinary.zip?OSSAccessKeyId=ri&Expires=1725539627&Signature=rb8q3OpV2i3gZJ"
ConnectorParameters	object	The connector parameters.
Config	object	The connector configuration.	{ "connector.class": "com.mongodb.kafka.connect.MongoSinkConnector", "tasks.max": "1", "topics": "sourceA,sourceB" }
Name	string	The connector name.	test-name
WorkerParameters	object	The instance configuration.	{ "group.id": "connect-eb-cluster-KAFKA_CONNECTORC", "offset.storage.topic": "connect-eb-offset-KAFKA_CONNECTOR_yjqC8K5ewC", "config.storage.topic": "connect-eb-config-KAFKA_CONNECTOR_yjqC8K5ewC", "status.storage.topic": "connect-eb-status-KAFKA_CONNECTOR_yjqC8K5ewC", "consumer.group.id": "connector-eb-cluster-KAFKA_CONNECTOR_yjqC8K5ewC-mongo-sink", "bootstrap.servers": "alikafka-post:9092" }
SourceCustomizedKafkaParameters	object	The custom Kafka event source.
InstanceId	string	The instance ID of the ApsaraMQ for Kafka instance.	r-8vb64581862c****
SourceDTSParameters	object	The Source DTS parameters.
BrokerUrl	string	The network address and port number of the data subscription channel.
InitCheckPoint	string	The consumer offset, which is the timestamp when the SDK client consumes the first data record. The value is a UNIX timestamp.	1620962769
Password	string	The password of the consumer group account.	admin****
Sid	string	The consumer group ID.	HD1
TaskId	string	The task ID.	f86e5814-b223-482c-b768-3b873297****
Topic	string	The subscription topic of the data subscription channel.	TP_TEST_UNDERWRITE_ISSUE
Username	string	The account of the consumer group.	admin
SourceEventBusParameters	object	The Source event bus parameters.
EventBusName	string	The name of the event bus.	demo
EventRuleName	string	The name of the event rule.	test
SourceFeiShuDocsParameters	SourceFeiShuDocsParameters
SourceJDBCParameters	SourceJDBCParameters
SourceKafkaParameters	object	The Source Kafka parameters.
ConsumerGroup	string	The group ID of the consumer that subscribes to the topic.	GID_TEST
InstanceId	string	The instance ID.	i-bp1fbtrnqmjvgq66****
Network	string	The network configuration. Default value: Default. Set the value to PublicNetwork for VPC networks.	Default
OffsetReset	string	The offset.	latest
RegionId	string	The region ID of the instance.	cn-hangzhou
SecurityGroupId	string	The security group ID.	sg-2vcgdxz7o1n9zapp****
Topic	string	The topic name.	topic_empower_1642473600414
VSwitchIds	string	The vSwitch ID.	vsw-wz9qqeovkwjxlu9uc****
ValueDataType	string	The encoding and decoding method. Valid values: JSON: The bytes are decoded into a string by using UTF-Base64 encoding and then parsed as JSON. Text: The bytes are decoded into a string by using UTF-Base64 encoding and directly placed into the payload. Binary: The bytes are Base64-encoded into a string and placed into the payload.	Text
VpcId	string	VPC ID	vpc-2zehizpoendb3****
SourceMNSParameters	object	The Source Simple Message Queue (formerly MNS) parameters.
IsBase64Decode	boolean	Specifies whether to enable Base64 encoding.	true
QueueName	string	The name of the Simple Message Queue (formerly MNS) queue.	demo
RegionId	string	The region ID.	cn-hangzhou
SourceMQTTParameters	object	The Source MQTT parameters.
BodyDataType	string	The message encoding format. Valid values: JSON Text Binary	JSON
InstanceId	string	The instance ID.	i-2ze06wqdwk0uq14k****
NetworkType	string	The network type.
RegionId	string	The region ID.	cn-shanghai
SecurityGroupId	string	The security group ID.
Topic	string	The topic name.	TOPIC-cainiao-pcs-wms-instock-noPrealertPrintLabel
VSwitchIds	string	The vSwitch ID.
VpcId	string	VPC ID。
SourceMySQLParameters	SourceMySQLParameters	The Source MySQL parameters.
SourceOSSParameters	object	The Source OSS event source.
BucketName	string	The name of the Object Storage Service (OSS) bucket.	bucket_abc
Delimiter	string	The delimiter. In chunked loading mode, this delimiter is used as the chunk identifier for the text. By default, the newline character \n is used as the delimiter.	\n
LoadFormat	string	The document loader.	TextLoader
LoadMode	string	The data loading mode. The value single indicates single-document loading, and the value element indicates chunked loading. Valid values: single and element. Default value: single.	single
Prefix	string	The file path prefix.	fun/document/
RoleName	string	The name of the role that provides authorization for the event bus EventBridge to read OSS files. The role must have at least read-only permissions on OSS.	eventbridge_oss_role
SourceOpenSourceRabbitMQParameters	object	The Source open source RabbitMQ parameters.
AuthType	string	The authentication type.	ACL
BodyDataType	string	The message encoding format. Valid values: JSON Text Binary	Json
Endpoint	string	The endpoint of the open source RabbitMQ instance.	192.168.1.100:5672
NetworkType	string	The network type. Valid values: PublicNetwork: public network. PrivateNetwork: VPC.	PrivateNetwork
Password	string	The password.	******
QueueName	string	The name of the queue on the open source RabbitMQ instance.	demo
SecurityGroupId	string	The security group ID.	sg-2ze65razphjfz3******
Username	string	The username.	admin
VSwitchIds	string	The vSwitch ID.	vsw-uf65zhil5oukof5******
VirtualHostName	string	The name of the vhost on the open source RabbitMQ instance.	eb-connect
VpcId	string	The ID of the VPC.	vpc-bp1vllc1lnw1v657******
SourcePostgreSQLParameters	SourcePostgreSQLParameters
SourcePrometheusParameters	object	The Source Prometheus event source.
ClusterId	string	The cluster ID.	c83555068b6******ad213f565f209
DataType	string	The data type.	Json
ExternalLabels	string	The external labels appended to the event stream.	{"env":"test"}
Labels	string	The labels.	__name__=.*
RegionId	string	The region ID.	cn-hangzhou
RoleName	string	The task role name.	test-role
SourceRabbitMQMetaParameters	SourceRabbitMQMetaParameters
SourceRabbitMQMsgSyncParameters	SourceRabbitMQMsgSyncParameters
SourceRabbitMQParameters	object	The Source RabbitMQ source.
InstanceId	string	The ID of the ApsaraMQ for RabbitMQ instance.	i-f8z9a9mcgwri1c1i****
QueueName	string	The name of the queue on the ApsaraMQ for RabbitMQ instance.	comp
RegionId	string	The region ID.	cn-hangzhou
VirtualHostName	string	The name of the vhost on the ApsaraMQ for RabbitMQ instance.	eb-connect
SourceRocketMQCheckpointParameters	object	The Source RocketMQ checkpoint parameters.
InstanceId	string	The instance ID.	rmp-cn-jte3w******
InstanceType	string	The instance type. Valid values: Cloud_4: ApsaraMQ for RocketMQ 4.0 instance (default) Cloud_5: ApsaraMQ for RocketMQ 5.0 instance SelfBuilt: self-managed Apache RocketMQ cluster	Cloud_4
RegionId	string	The region ID.	cn-hangzhou
Topics	array	The message topic.
	string	The message topic.	opic_add_anima
SourceRocketMQParameters	object	The Source RocketMQ source.
AuthType	string	The authentication type.	ACL
BodyDataType	string	The encoding format of the message body. Valid values: Json Text Binary	Json
FilterSql	string	The SQL filter statement.	index > 10
FilterType	string	The message filter type.	Tag
GroupID	string	The group ID of the ApsaraMQ for RocketMQ instance.	GID_group1
InstanceEndpoint	string	The instance endpoint.	reg****-vpc.cn-zhangjiakou.aliyuncs.com
InstanceId	string	The instance ID of the ApsaraMQ for RocketMQ instance.	i-f8zbher64dlm58pl****
InstanceNetwork	string	The instance network information. Valid values: PublicNetwork PrivateNetwork	PublicNetwork
InstancePassword	string	The instance password.	xxxa
InstanceSecurityGroupId	string	The security group information of the instance.	sg-m5edtu24f12345****
InstanceType	string	The instance type. Valid values: Cloud_4: ApsaraMQ for RocketMQ 4.0 instance (default) Cloud_5: ApsaraMQ for RocketMQ 5.0 instance SelfBuilt: self-managed Apache RocketMQ cluster	Cloud_4
InstanceUsername	string	The username of the instance.	xxxa
InstanceVSwitchIds	string	The vSwitch information of the instance.	vsw-m5ev8asdc6h12****
InstanceVpcId	string	The VPC information of the instance.	vpc-m5e3sv4b12345****
Network	string	The network type. Valid values: PublicNetwork PrivateNetwork	PublicNetwork
Offset	string	The consumption offset of the message. Valid values: CONSUME_FROM_LAST_OFFSET: Consumption starts from the latest offset. CONSUME_FROM_FIRST_OFFSET: Consumption starts from the earliest offset. CONSUME_FROM_TIMESTAMP: Consumption starts from the offset at a specified point in time.	CONSUMEFROMLASTOFFSET
RegionId	string	The region ID of the ApsaraMQ for RocketMQ instance.	cn-hangzhou
SecurityGroupId	string	The security group ID.	sg-m5edtu24f12345****
Tag	string	The filter tag of the message.	v1
Timestamp	integer	The timestamp. This parameter is valid only when the Offset parameter is set to CONSUME_FROM_TIMESTAMP.	1636597951964
Topic	string	The topic of the message.	topic_add_anima
VSwitchIds	string	The vSwitch ID.	vsw-m5ev8asdc6h12345****
VpcId	string	The ID of the VPC.	vpc-m5e3sv4b12345****
SourceSLSParameters	object	The Source SLS source.
ConsumePosition	string	The starting consumption offset. You can select the earliest or latest offset, which corresponds to "begin" or "end" respectively. You can also start consumption from a specified point in time, in seconds.	begin
ConsumerGroup	string	The consumer group.
LogStore	string	The Logstore of Simple Log Service (SLS).	waf-logstore
Project	string	The project of Simple Log Service (SLS).	dmmzk
RoleName	string	The role that provides authorization for the event bus EventBridge to read SLS log content. To use this role, create a role for the service in the Resource Access Management (RAM) console, select "Alibaba Cloud Service", and set "Trusted Service" to "event bus".	testRole
Status	string	The status of the event stream.	RUNNING
Transforms	array<object>	The Transform configurations.
	object	The Alibaba Cloud Resource Name (ARN) of the cloud resource, such as the ARN of a function in Function Compute.
AiChunkTransformParameters	AiChunkTransformParameters	The AI local text chunking parameters.
AiClassifyTransformParameters	AiClassifyTransformParameters	The AI text classification parameters.
AiEmbedTransformParameters	AiEmbedTransformParameters	The AI embedding parameters.
AiExtractTransformParameters	AiExtractTransformParameters	The AI information extraction parameters.
AiFilterTransformParameters	AiFilterTransformParameters	The AI conditional filtering parameters.
AiPrepSearchTransformParameters	AiPrepSearchTransformParameters	The AI semantic chunking parameters.
AiRedactTransformParameters	AiRedactTransformParameters	The AI data masking parameters.
AiSentimentAnalysisTransformParameters	AiSentimentAnalysisTransformParameters	The AI sentiment analysis parameters.
AiSummarizeTransformParameters	AiSummarizeTransformParameters	The AI summarization parameters.
AiTranslateTransformParameters	AiTranslateTransformParameters	The AI translation parameters.
Arn	string	The Alibaba Cloud Resource Name (ARN) of the cloud resource, such as the ARN of a function in Function Compute.	acs:fc:cn-hangzhou:*****:services/demo-service.LATEST/functions/demo-func
BaiLianAgentTransformParameters	BaiLianAgentTransformParameters
DashScopeTransformParameters	DashScopeTransformParameters
Message	string	The error message.	The event streaming [xxxx] not existed!
RequestId	string	The unique identifier that Alibaba Cloud generated for the request.	7892F480-58C9-5067-AB35-8A7BEF****
Success	boolean	Returns true if the operation is successful.	true

Examples

Success response

JSON format

{
  "Code": "Success",
  "Data": {
    "Description": "RocketMQ-to-RocketMQ",
    "DetailedStatus": {
      "DelayTime": 3,
      "DiffOffset": 0,
      "Extensions": {
        "test": "test",
        "test2": 1
      },
      "TPS": 5
    },
    "EventStreamingName": "rocketmq-sync",
    "FilterPattern": "",
    "Metadata": "",
    "RunOptions": {
      "BatchWindow": {
        "CountBasedWindow": 100,
        "TimeBasedWindow": 10
      },
      "BusinessOption": {
        "BusinessMode": "",
        "MaxCapacityUnitCount": 0,
        "MinCapacityUnitCount": 0
      },
      "DeadLetterQueue": {
        "Arn": "acs:ram::155020394332****:role/edskmstoecs",
        "Network": "PrivateNetwork",
        "SecurityGroupId": "sg-2vcgdxz7o1n9zapp****",
        "VSwitchIds": "vsw-m5ev8asdc6h12345****",
        "VpcId": "vpc-2zehizpoendb3****"
      },
      "ErrorsTolerance": "ALL",
      "MaximumTasks": 2,
      "RetryStrategy": {
        "MaximumEventAgeInSeconds": 512,
        "MaximumRetryAttempts": 2,
        "PushRetryStrategy": "BACKOFF_RETRY"
      },
      "Throttling": 0
    },
    "Sink": {
      "SinkAgentRunParameters": {
        "AgentRuntimeName": "",
        "EndpointName": "",
        "RoleName": "",
        "Body": {
          "Value": "",
          "Form": "",
          "Template": ""
        },
        "Timeout": ""
      },
      "SinkApacheKafkaParameters": {
        "Acks": "",
        "Bootstraps": "",
        "CompressionType": "",
        "DynamicTopic": {
          "Form": "",
          "Template": "",
          "Value": ""
        },
        "Headers": {
          "Form": "",
          "Template": "",
          "Value": ""
        },
        "Key": {
          "Form": "",
          "Template": "",
          "Value": ""
        },
        "NetworkType": {
          "Form": "",
          "Template": "",
          "Value": ""
        },
        "SaslMechanism": "",
        "SaslPassword": "",
        "SaslUser": "",
        "SecurityGroupId": {
          "Form": "",
          "Template": "",
          "Value": ""
        },
        "SecurityProtocol": "",
        "SslKeyPassword": "",
        "SslKeystoreCertificateChain": "",
        "SslKeystoreKey": {
          "KmsArn": "",
          "KmsSecretValueKey": ""
        },
        "SslTruststoreCertificates": "",
        "Topic": "",
        "VSwitchIds": {
          "Form": "",
          "Template": "",
          "Value": ""
        },
        "Value": {
          "Form": "",
          "Template": "",
          "Value": ""
        },
        "VpcId": {
          "Form": "",
          "Template": "",
          "Value": ""
        }
      },
      "SinkApacheRocketMQCheckpointParameters": {
        "ConsumeTimestamp": {
          "Form": "CONSTANT",
          "Template": "",
          "Value": "1570761026400"
        },
        "Group": {
          "Form": "CONSTANT",
          "Template": "",
          "Value": "GID_EVENTBRIDGE_1736234******\n"
        },
        "InstanceEndpoint": "192.168.1.1:9876",
        "InstancePassword": "****",
        "InstanceUsername": "admin",
        "NetworkType": "PrivateNetwork",
        "SecurityGroupId": "sg-2ze5bmpw6adn0q******",
        "Topic": {
          "Form": "CONSTANT",
          "Template": "",
          "Value": "Mytopic"
        },
        "VSwitchId": "vsw-uf62oqt1twuevrt******",
        "VpcId": "vpc-2zeccak5pb0j3ay******"
      },
      "SinkApiDestinationParameters": {
        "Name": "",
        "HeaderParameters": {
          "Form": "",
          "Value": "",
          "Template": ""
        },
        "BodyParameters": {
          "Form": "",
          "Value": "",
          "Template": ""
        },
        "QueryStringParameters": {
          "Form": "",
          "Value": "",
          "Template": ""
        },
        "Timeout": 0
      },
      "SinkCustomizedKafkaConnectorParameters": {
        "ConnectorPackageUrl": "\"https://examplebucket.oss-cn-hangzhou.aliyuncs.com/testDoc/Old_Homebrew/2024-06-26%2022%3A34%3A08/opt/homebrew/homebrew/Library/Homebrew/test/support/fixtures/cask/AppWithBinary.zip?OSSAccessKeyId=ri&Expires=1725539627&Signature=rb8q3OpV******\"",
        "ConnectorParameters": {
          "Config": {
            "connector.class": "com.mongodb.kafka.connect.MongoSinkConnector",
            "tasks.max": "1",
            "topics": "sourceA,sourceB"
          },
          "Name": "mongo-sink"
        },
        "WorkerParameters": {
          "group.id": "connect-eb-cluster-KAFKA_CONNECTORC",
          "offset.storage.topic": "connect-eb-offset-KAFKA_CONNECTOR_yjqC8K5ewC",
          "config.storage.topic": "connect-eb-config-KAFKA_CONNECTOR_yjqC8K5ewC",
          "status.storage.topic": "connect-eb-status-KAFKA_CONNECTOR_yjqC8K5ewC",
          "consumer.group.id": "connector-eb-cluster-KAFKA_CONNECTOR_yjqC8K5ewC-mongo-sink",
          "bootstrap.servers": "alikafka-post:9092"
        }
      },
      "SinkCustomizedKafkaParameters": {
        "InstanceId": "90be1f96-4229-4535-bb76-34b4f6fb****"
      },
      "SinkDashVectorParameters": {
        "ApiKey": "Q34nExQH7sQ****",
        "Collection": "collection1",
        "DashVectorSchemaParameters": [
          {
            "Name": {
              "Form": "",
              "Template": "",
              "Value": ""
            },
            "Type": {
              "Form": "",
              "Template": "",
              "Value": ""
            },
            "Value": {
              "Form": "",
              "Template": "",
              "Value": ""
            }
          }
        ],
        "InstanceId": "vrs-cn-lbj3ru1***",
        "Network": "PublicNetwork",
        "Operation": "Upsert",
        "Partition": {
          "Form": "CONSTANT",
          "Template": "",
          "Value": "default"
        },
        "PrimaryKeyId": {
          "Form": "JSONPATH",
          "Template": "${ID}",
          "Value": "$.data.requestId"
        },
        "Vector": {
          "Form": "JSONPATH",
          "Template": "",
          "Value": "$.data.messageBody"
        }
      },
      "SinkDataHubParameters": {
        "Body": {
          "Form": "ORIGINAL",
          "Template": "",
          "Value": ""
        },
        "Project": {
          "Form": "CONSTANT\n",
          "Template": "\n\n",
          "Value": "demo-project\n"
        },
        "RoleName": {
          "Form": "CONSTANT",
          "Template": "",
          "Value": "test-role"
        },
        "Topic": {
          "Form": "CONSTANT",
          "Template": "",
          "Value": "demo-topic\n"
        },
        "TopicSchema": {
          "Form": "TEMPLATE",
          "Template": "{\"k1\":\"${k1}\",\"k2\":\"${k2}\"}",
          "Value": "{\"k1\":\"value1\",\"k2\":\"value2\"}"
        },
        "TopicType": {
          "Form": "CONSTANT",
          "Template": "",
          "Value": "TUPLE\n"
        }
      },
      "SinkDataWorksTriggerParameters": {
        "Enable": ""
      },
      "SinkDorisParameters": {
        "BeHttpEndpoint": {
          "Form": "",
          "Template": "",
          "Value": ""
        },
        "Body": {
          "Form": "",
          "Template": "",
          "Value": ""
        },
        "Database": {
          "Form": "",
          "Template": "",
          "Value": ""
        },
        "FeHttpEndpoint": {
          "Form": "",
          "Template": "",
          "Value": ""
        },
        "NetworkType": {
          "Form": "",
          "Template": "",
          "Value": ""
        },
        "Password": {
          "Form": "",
          "Template": "",
          "Value": ""
        },
        "QueryEndpoint": {
          "Form": "",
          "Template": "",
          "Value": ""
        },
        "SecurityGroupId": {
          "Form": "",
          "Template": "",
          "Value": ""
        },
        "Table": {
          "Form": "",
          "Template": "",
          "Value": ""
        },
        "UserName": {
          "Form": "",
          "Template": "",
          "Value": ""
        },
        "VSwitchIds": {
          "Form": "",
          "Template": "",
          "Value": ""
        },
        "VpcId": {
          "Form": "",
          "Template": "",
          "Value": ""
        }
      },
      "SinkFcParameters": {
        "Body": {
          "Form": "TEMPLATE",
          "Template": "The value of ${key} is ${value}!\n",
          "Value": "{\n      \"key\": \"value\"\n}"
        },
        "Concurrency": {
          "Form": "CONSTANT",
          "Template": "The value of ${key} is ${value}!\n",
          "Value": "1"
        },
        "DataFormat": {
          "Form": "JSONPATH",
          "Template": "$.data.key",
          "Value": "{\n      \"key\": \"value\"\n}"
        },
        "FunctionName": {
          "Form": "CONSTANT",
          "Template": "The value of ${key} is ${value}!\n",
          "Value": "mFunction"
        },
        "InvocationType": {
          "Form": "CONSTANT",
          "Template": "The value of ${key} is ${value}!\n",
          "Value": "Async"
        },
        "Qualifier": {
          "Form": "CONSTANT",
          "Template": "The value of ${key} is ${value}!\n",
          "Value": "LATEST"
        },
        "ServiceName": {
          "Form": "CONSTANT",
          "Template": "The value of ${key} is ${value}!\n",
          "Value": "myService"
        }
      },
      "SinkFnfParameters": {
        "ExecutionName": {
          "Form": "CONSTANT",
          "Template": "",
          "Value": "123"
        },
        "FlowName": {
          "Form": "CONSTANT",
          "Template": "",
          "Value": "test-streaming-fnf"
        },
        "Input": {
          "Form": "CONSTANT",
          "Template": "",
          "Value": "123"
        },
        "RoleName": {
          "Form": "CONSTANT",
          "Template": "",
          "Value": "Al****FNF-x****"
        }
      },
      "SinkHttpsParameters": {
        "URL": {
          "Form": "",
          "Value": "",
          "Template": ""
        },
        "Method": "",
        "Body": {
          "Form": "",
          "Value": "",
          "Template": ""
        },
        "Token": "",
        "NetworkType": "",
        "VpcId": "",
        "VSwitchIds": "",
        "SecurityGroupId": ""
      },
      "SinkKafkaParameters": {
        "Acks": {
          "Form": "CONSTANT",
          "Template": "The value of ${key} is ${value}!\n",
          "Value": "1"
        },
        "CompressionType": "",
        "DynamicTopic": {
          "Form": "",
          "Template": "",
          "Value": ""
        },
        "Headers": {
          "Form": "CONSTANT",
          "Template": "The value of ${key} is ${value}!\n",
          "Value": "{\n      \"key\": \"value\"\n}\n\n"
        },
        "InstanceId": {
          "Form": "CONSTANT",
          "Template": "The value of ${key} is ${value}!\n",
          "Value": "Defaut_1283278472_s****"
        },
        "Key": {
          "Form": "CONSTANT",
          "Template": "The value of ${key} is ${value}!\n",
          "Value": "key"
        },
        "Topic": {
          "Form": "CONSTANT",
          "Template": "The value of ${key} is ${value}!\n",
          "Value": "test"
        },
        "Value": {
          "Form": "TEMPLATE",
          "Template": "The value of ${key} is ${value}!\n",
          "Value": "{\n      \"key\": \"value\"\n}"
        }
      },
      "SinkKnowledgeBaseParameters": {
        "Catalog": "my_catalog",
        "KnowledgeBaseName": "my-knowledge-base",
        "Namespace": "my_namespace"
      },
      "SinkMNSParameters": {
        "Body": {
          "Form": "TEMPLATE",
          "Template": "The value of ${key} is ${value}!",
          "Value": "{\n      \"key\": \"value\"\n}"
        },
        "IsBase64Encode": {
          "Form": "CONSTANT",
          "Template": "",
          "Value": "true"
        },
        "QueueName": {
          "Form": "CONSTANT",
          "Template": "",
          "Value": "MyQueue"
        }
      },
      "SinkMQTTParameters": {
        "InstanceId": "",
        "ParentTopic": "",
        "SubTopic": {
          "Form": "",
          "Value": "",
          "Template": ""
        },
        "Payload": {
          "Form": "",
          "Value": "",
          "Template": ""
        },
        "Mqtt5UserProperty": {
          "Form": "",
          "Value": "",
          "Template": ""
        }
      },
      "SinkOSSParameters": {
        "BucketName": "",
        "RegionId": "",
        "Endpoint": "",
        "RoleArn": "",
        "RotateSizeBytes": "",
        "RotateIntervalMs": "",
        "PathFormat": "",
        "CompressionType": "",
        "TaskConcurrency": "",
        "TimeZone": "",
        "SSLEnabled": true,
        "ContentTransform": {
          "Form": "",
          "Value": "",
          "Template": ""
        }
      },
      "SinkOpenSourceRabbitMQParameters": {
        "AuthType": "ACL",
        "Body": {
          "Form": "CONSTANT",
          "Template": "The value of ${key} is ${value}!",
          "Value": "{\"key\": \"value\"}"
        },
        "Endpoint": "192.168.1.1:9876",
        "Exchange": "my-exchange",
        "MessageId": {
          "Form": "CONSTANT",
          "Template": "",
          "Value": "12345"
        },
        "NetworkType": "PublicNetwork\n",
        "Password": "****",
        "Properties": {
          "Form": "CONSTANT",
          "Template": "The value of ${key} is ${value}!\n",
          "Value": "{\"env\": \"prod\"}"
        },
        "QueueName": "my-queue",
        "RoutingKey": {
          "Form": "CONSTANT",
          "Template": "The value of ${key} is ${value}!",
          "Value": "{\"Form\": \"CONSTANT\", \"Value\": \"my-routing-key\"}\n"
        },
        "SecurityGroupId": "sg-uf6of9452b2pba82c ****",
        "TargetType": "Exchange",
        "Username": "admin",
        "VSwitchIds": "vsw-uf6of9452b2pba82c ****",
        "VirtualHostName": "vhost1",
        "VpcId": "vpc-uf6of9452b2pba82c ****"
      },
      "SinkRabbitMQMetaParameters": {
        "InstanceType": "",
        "InstanceId": "",
        "Endpoint": "",
        "VirtualHostName": "",
        "Username": "",
        "Password": "",
        "VpcId": "",
        "VSwitchIds": "",
        "SecurityGroupId": "",
        "NetworkType": ""
      },
      "SinkRabbitMQMsgSyncParameters": {
        "InstanceType": "",
        "InstanceId": "",
        "Endpoint": "",
        "VirtualHostName": "",
        "Body": {
          "Form": "",
          "Value": "",
          "Template": ""
        },
        "MessageId": {
          "Form": "",
          "Value": "",
          "Template": ""
        },
        "Properties": {
          "Form": "",
          "Value": "",
          "Template": ""
        },
        "Exchange": {
          "Form": "",
          "Value": "",
          "Template": ""
        },
        "RoutingKey": {
          "Form": "",
          "Value": "",
          "Template": ""
        },
        "MaxHops": "",
        "Username": "",
        "Password": "",
        "VpcId": "",
        "VSwitchIds": "",
        "SecurityGroupId": "",
        "NetworkType": ""
      },
      "SinkRabbitMQParameters": {
        "Body": {
          "Form": "TEMPLATE",
          "Template": "The value of ${key} is ${value}!",
          "Value": "{\n      \"key\": \"value\"\n}"
        },
        "Exchange": {
          "Form": "CONSTANT",
          "Template": "The value of ${key} is ${value}!\n",
          "Value": "a_exchange"
        },
        "InstanceId": {
          "Form": "CONSTANT",
          "Template": "The value of ${key} is ${value}!\n",
          "Value": "e5c9b727-e06c-4d7e-84d5-f8ce644e****"
        },
        "MessageId": {
          "Form": "TEMPLATE",
          "Template": "The value of ${key} is ${value}!",
          "Value": "{\n      \"key\": \"value\"\n}"
        },
        "Properties": {
          "Form": "TEMPLATE",
          "Template": "The value of ${key} is ${value}!\n",
          "Value": "{\n      \"key\": \"value\"\n}"
        },
        "QueueName": {
          "Form": "CONSTANT",
          "Template": "The value of ${key} is ${value}!\n",
          "Value": "MyQueue"
        },
        "RoutingKey": {
          "Form": "CONSTANT",
          "Template": "The value of ${key} is ${value}!\n",
          "Value": "housekeeping"
        },
        "TargetType": {
          "Form": "CONSTANT",
          "Template": "The value of ${key} is ${value}!\n",
          "Value": "Exchange/Queue"
        },
        "VirtualHostName": {
          "Form": "CONSTANT",
          "Template": "",
          "Value": "rabbit-host\n"
        }
      },
      "SinkRocketMQCheckpointParameters": {
        "ConsumeTimestamp": {
          "Form": "CONSTANT",
          "Template": "",
          "Value": "1570761026400"
        },
        "Group": {
          "Form": "CONSTANT",
          "Template": "",
          "Value": "GID_EVENTBRIDGE_1736234******"
        },
        "InstanceId": "MQ_INST_164901546557****_BAAN****",
        "InstanceType": "Cloud_4",
        "Topic": {
          "Form": "CONSTANT",
          "Template": "",
          "Value": "Mytopic"
        }
      },
      "SinkRocketMQParameters": {
        "Body": {
          "Form": "TEMPLATE",
          "Template": "The value of ${key} is ${value}!\n",
          "Value": "{\n      \"key\": \"value\"\n}"
        },
        "DeliveryOrderType": {
          "Form": "CONSTANT",
          "Template": "",
          "Value": "Concurrently"
        },
        "InstanceEndpoint": {
          "Form": "CONSTANT\n",
          "Template": "",
          "Value": "vbr-8vbsvkkbpf3vb0zef****\n"
        },
        "InstanceId": {
          "Form": "CONSTANT",
          "Template": "The value of ${key} is ${value}!\n",
          "Value": "MQ_INST_164901546557****_BAAN****"
        },
        "InstancePassword": {
          "Form": "CONSTANT\n",
          "Template": "",
          "Value": "admin****\n"
        },
        "InstanceType": {
          "Form": "CONSTANT",
          "Template": "",
          "Value": "Cloud_4\n"
        },
        "InstanceUsername": {
          "Form": "CONSTANT\n",
          "Template": "",
          "Value": "admin\n"
        },
        "Keys": {
          "Form": "TEMPLATE",
          "Template": "The value of ${key} is ${value}!",
          "Value": "{\n      \"key\": \"value\"\n}"
        },
        "Network": {
          "Form": "CONSTANT\n",
          "Template": "\n",
          "Value": "PublicNetwork\n"
        },
        "Properties": {
          "Form": "TEMPLATE",
          "Template": "The value of ${key} is ${value}!\n",
          "Value": "{\n      \"key\": \"value\"\n}"
        },
        "SecurityGroupId": {
          "Form": "CONSTANT\n",
          "Template": "",
          "Value": "b4bf375515f6440f942e3a20c33d****\n"
        },
        "ShardingKey": {
          "Form": "CONSTANT",
          "Template": "",
          "Value": "order_id"
        },
        "Tags": {
          "Form": "TEMPLATE",
          "Template": "The value of ${key} is ${value}!",
          "Value": "{\n      \"key\": \"value\"\n}"
        },
        "Topic": {
          "Form": "CONSTANT",
          "Template": "The value of ${key} is ${value}!\n",
          "Value": "Mytopic"
        },
        "VSwitchIds": {
          "Form": "CONSTANT\n",
          "Template": "\n",
          "Value": "vbr-8vb835n3zf9shwl****mp\n"
        },
        "VpcId": {
          "Form": "CONSTANT\n",
          "Template": "\n",
          "Value": "vbr-8vb835n3zf9shwlvb****\n"
        }
      },
      "SinkSLSParameters": {
        "Body": {
          "Form": "TEMPLATE",
          "Template": "The value of ${key} is ${value}!\n",
          "Value": "{\n      \"key\": \"value\"\n}"
        },
        "ContentSchema": {
          "Form": "CONSTANT\n",
          "Template": "",
          "Value": "{\"Key_1\":{\"form\":\"CONSTANT\",\"value\":\"demoKey\"},\"Value_1\":{\"form\":\"JSONPATH\",\"value\":\"$.data.value\"}}"
        },
        "ContentType": {
          "Form": "CONSTANT\n",
          "Template": "",
          "Value": "JSON\n"
        },
        "LogStore": {
          "Form": "CONSTANT",
          "Template": "",
          "Value": "test-logstore"
        },
        "Project": {
          "Form": "CONSTANT",
          "Template": "",
          "Value": "test-project\n"
        },
        "RoleName": {
          "Form": "CONSTANT",
          "Template": "",
          "Value": "testRole"
        },
        "Topic": {
          "Form": "CONSTANT",
          "Template": "",
          "Value": "testTopic"
        }
      }
    },
    "Source": {
      "SourceApacheKafkaParameters": {
        "Bootstraps": "",
        "ConsumerGroup": "",
        "NetworkType": "",
        "OffsetReset": "",
        "SaslMechanism": "",
        "SaslPassword": "",
        "SaslUser": "",
        "SecurityGroupId": "",
        "SecurityProtocol": "",
        "SslKeyPassword": "",
        "SslKeystoreCertificateChain": "",
        "SslKeystoreKey": {
          "KmsArn": "",
          "KmsSecretValueKey": ""
        },
        "SslTruststoreCertificates": "",
        "Topic": "",
        "VSwitchIds": "",
        "ValueDataType": "",
        "VpcId": ""
      },
      "SourceApacheRocketMQCheckpointParameters": {
        "InstanceEndpoint": "registry-vpc.cn-hangzhou.aliyuncs.com",
        "InstanceId": "MQ_INST_164901546557****_BAAN****",
        "InstancePassword": "123456",
        "InstanceUsername": "admin",
        "NetworkType": "PrivateNetwork",
        "RegionId": "cn-hangzhou\n",
        "SecurityGroupId": "sg-mw43*****",
        "Topics": [
          "[\"Topic_1\",\"Topic_2\"]"
        ],
        "VSwitchId": "vsw-dwaafds****",
        "VpcId": "vpc-adw1awdw*****"
      },
      "SourceCustomizedKafkaConnectorParameters": {
        "ConnectorPackageUrl": "\"https://examplebucket.oss-cn-hangzhou.aliyuncs.com/testDoc/Old_Homebrew/2024-06-26%2022%3A34%3A08/opt/homebrew/homebrew/Library/Homebrew/test/support/fixtures/cask/AppWithBinary.zip?OSSAccessKeyId=ri&Expires=1725539627&Signature=rb8q3OpV2i3gZJ\"",
        "ConnectorParameters": {
          "Config": {
            "connector.class": "com.mongodb.kafka.connect.MongoSinkConnector",
            "tasks.max": "1",
            "topics": "sourceA,sourceB"
          },
          "Name": "test-name\n"
        },
        "WorkerParameters": {
          "group.id": "connect-eb-cluster-KAFKA_CONNECTORC",
          "offset.storage.topic": "connect-eb-offset-KAFKA_CONNECTOR_yjqC8K5ewC",
          "config.storage.topic": "connect-eb-config-KAFKA_CONNECTOR_yjqC8K5ewC",
          "status.storage.topic": "connect-eb-status-KAFKA_CONNECTOR_yjqC8K5ewC",
          "consumer.group.id": "connector-eb-cluster-KAFKA_CONNECTOR_yjqC8K5ewC-mongo-sink",
          "bootstrap.servers": "alikafka-post:9092"
        }
      },
      "SourceCustomizedKafkaParameters": {
        "InstanceId": "r-8vb64581862c****\n"
      },
      "SourceDTSParameters": {
        "BrokerUrl": "",
        "InitCheckPoint": "1620962769",
        "Password": "admin****",
        "Sid": "HD1",
        "TaskId": "f86e5814-b223-482c-b768-3b873297****",
        "Topic": "TP_TEST_UNDERWRITE_ISSUE",
        "Username": "admin"
      },
      "SourceEventBusParameters": {
        "EventBusName": "demo",
        "EventRuleName": "test"
      },
      "SourceFeiShuDocsParameters": {
        "AppId": "cli_a946c046xxxx",
        "AppSecret": "yO3hEYiSjkBVxxxx",
        "KnowledgeSpaceName": "产品文档中心",
        "LoadMode": "single"
      },
      "SourceJDBCParameters": {
        "JdbcUrl": "",
        "Username": "",
        "Password": "",
        "QueryMode": "",
        "TableName": "",
        "IncrementingColumn": "",
        "TimestampColumn": "",
        "PollingInterval": 0,
        "BatchSize": 0,
        "QueryTimeout": 0,
        "CustomQuery": "",
        "Network": "",
        "VpcId": "",
        "VSwitchIds": "",
        "SecurityGroupId": ""
      },
      "SourceKafkaParameters": {
        "ConsumerGroup": "GID_TEST",
        "InstanceId": "i-bp1fbtrnqmjvgq66****",
        "Network": "Default",
        "OffsetReset": "latest",
        "RegionId": "cn-hangzhou",
        "SecurityGroupId": "sg-2vcgdxz7o1n9zapp****",
        "Topic": "topic_empower_1642473600414",
        "VSwitchIds": "vsw-wz9qqeovkwjxlu9uc****",
        "ValueDataType": "Text",
        "VpcId": "vpc-2zehizpoendb3****"
      },
      "SourceMNSParameters": {
        "IsBase64Decode": true,
        "QueueName": "demo",
        "RegionId": "cn-hangzhou"
      },
      "SourceMQTTParameters": {
        "BodyDataType": "JSON",
        "InstanceId": "i-2ze06wqdwk0uq14k****",
        "NetworkType": "",
        "RegionId": "cn-shanghai",
        "SecurityGroupId": "",
        "Topic": "TOPIC-cainiao-pcs-wms-instock-noPrealertPrintLabel",
        "VSwitchIds": "",
        "VpcId": ""
      },
      "SourceOSSParameters": {
        "BucketName": "bucket_abc\n",
        "Delimiter": "\\n\n",
        "LoadFormat": "TextLoader\n",
        "LoadMode": "single\n",
        "Prefix": "fun/document/\n",
        "RoleName": "eventbridge_oss_role\n"
      },
      "SourceOpenSourceRabbitMQParameters": {
        "AuthType": "ACL",
        "BodyDataType": "Json",
        "Endpoint": "192.168.1.100:5672",
        "NetworkType": "PrivateNetwork\n",
        "Password": "******",
        "QueueName": "demo",
        "SecurityGroupId": "sg-2ze65razphjfz3******",
        "Username": "admin",
        "VSwitchIds": "vsw-uf65zhil5oukof5******",
        "VirtualHostName": "eb-connect",
        "VpcId": "vpc-bp1vllc1lnw1v657******"
      },
      "SourcePostgreSQLParameters": {
        "RegionId": "",
        "HostName": "",
        "Port": 0,
        "User": "",
        "Password": "",
        "DatabaseName": "",
        "SchemaName": "",
        "TableNames": "",
        "NetworkType": "",
        "VpcId": "",
        "VSwitchIds": "",
        "SecurityGroupId": "",
        "SnapshotMode": ""
      },
      "SourcePrometheusParameters": {
        "ClusterId": "c83555068b6******ad213f565f209\n",
        "DataType": "Json",
        "ExternalLabels": "{\"env\":\"test\"}",
        "Labels": "__name__=.*\n",
        "RegionId": "cn-hangzhou",
        "RoleName": "test-role"
      },
      "SourceRabbitMQMetaParameters": {
        "InstanceType": "",
        "InstanceId": "",
        "Endpoint": "",
        "VirtualHostName": "",
        "Regex": "",
        "Username": "",
        "Password": "",
        "VpcId": "",
        "VSwitchIds": "",
        "SecurityGroupId": "",
        "NetworkType": "",
        "MaxHops": "",
        "OrderConsume": "",
        "InnerNameSuffix": "",
        "SyncMetaType": ""
      },
      "SourceRabbitMQMsgSyncParameters": {
        "InstanceType": "",
        "InstanceId": "",
        "Endpoint": "",
        "VirtualHostName": "",
        "OrderConsume": "",
        "BodyDataType": "",
        "PrefetchCount": "",
        "Username": "",
        "Password": "",
        "VpcId": "",
        "VSwitchIds": "",
        "SecurityGroupId": "",
        "NetworkType": "",
        "SyncMetaType": "",
        "Regex": "",
        "SrcClusterType": "",
        "SrcClusterHost": "",
        "DstClusterType": "",
        "DstClusterHost": "",
        "CloudMigrationTaskId": ""
      },
      "SourceRabbitMQParameters": {
        "InstanceId": "i-f8z9a9mcgwri1c1i****",
        "QueueName": "comp",
        "RegionId": "cn-hangzhou",
        "VirtualHostName": "eb-connect"
      },
      "SourceRocketMQCheckpointParameters": {
        "InstanceId": "rmp-cn-jte3w******\n",
        "InstanceType": "Cloud_4",
        "RegionId": "cn-hangzhou",
        "Topics": [
          "opic_add_anima"
        ]
      },
      "SourceRocketMQParameters": {
        "AuthType": "ACL",
        "BodyDataType": "Json",
        "FilterSql": "index > 10",
        "FilterType": "Tag\n",
        "GroupID": "GID_group1",
        "InstanceEndpoint": "reg****-vpc.cn-zhangjiakou.aliyuncs.com\n",
        "InstanceId": "i-f8zbher64dlm58pl****",
        "InstanceNetwork": "PublicNetwork",
        "InstancePassword": "xxxa",
        "InstanceSecurityGroupId": "sg-m5edtu24f12345****\n",
        "InstanceType": "Cloud_4\n",
        "InstanceUsername": "xxxa",
        "InstanceVSwitchIds": "vsw-m5ev8asdc6h12****\n",
        "InstanceVpcId": "vpc-m5e3sv4b12345****\n",
        "Network": "PublicNetwork",
        "Offset": "CONSUMEFROMLASTOFFSET",
        "RegionId": "cn-hangzhou",
        "SecurityGroupId": "sg-m5edtu24f12345****\n",
        "Tag": "v1",
        "Timestamp": 1636597951964,
        "Topic": "topic_add_anima",
        "VSwitchIds": "vsw-m5ev8asdc6h12345****\n",
        "VpcId": "vpc-m5e3sv4b12345****\n"
      },
      "SourceSLSParameters": {
        "ConsumePosition": "begin",
        "ConsumerGroup": "",
        "LogStore": "waf-logstore",
        "Project": "dmmzk",
        "RoleName": "testRole"
      }
    },
    "Status": "RUNNING",
    "Transforms": [
      {
        "Arn": "acs:fc:cn-hangzhou:*****:services/demo-service.LATEST/functions/demo-func\n",
        "BaiLianAgentTransformParameters": {
          "ApplicationId": "",
          "Prompt": {
            "Form": "",
            "Value": "",
            "Template": ""
          },
          "ApiKey": "",
          "RequestPerMinute": 0,
          "TokenPerMinute": 0
        },
        "DashScopeTransformParameters": {
          "Model": "",
          "ApiKey": "",
          "StructuredOutputJsonSchema": "",
          "RequestPerMinute": 0,
          "TokenPerMinute": 0,
          "Messages": [
            {
              "Role": "",
              "Form": "",
              "Value": "",
              "Template": ""
            }
          ]
        }
      }
    ]
  },
  "Message": "The event streaming [xxxx] not existed!",
  "RequestId": "7892F480-58C9-5067-AB35-8A7BEF****",
  "Success": true
}

Error codes

HTTP status code	Error code	Error message	Description
403	ServiceNotEnable	Service not enable

See Error Codes for a complete list.

Release notes

See Release Notes for a complete list.