Retrieve a list of event streams by using ListEventStreamings - EventBridge - Alibaba Cloud - EventBridge

Queries event streams.

Operation description

Queries event streams.

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:ListEventStreamings

list

*EventStreaming

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

None

Request parameters

Parameter	Type	Required	Description	Example
NamePrefix	string	No	The name prefix of the event stream.	name
Limit	integer	No	The maximum number of entries to return per request. You can use this parameter together with NextToken to implement paging. Important The maximum number of entries to return per request cannot exceed 100.	10
NextToken	string	No	If the number of entries that match the specified conditions exceeds the value of Limit, a NextToken is returned.	10
Tags	array<object>	No	The tags used for filtering.
	object	No	The tag.
Key	string	No	The tag key.	mns
Value	string	No	The tag value.	mnstest
SourceArn	string	No	The Alibaba Cloud Resource Name (ARN) of the event source.	acs:alikafka:cn-hangzhou:118609547428**:instance/alikafka_pre-cn-zxu36kvi**/topic/test-topic
SinkArn	string	No	The ARN of the event target.	acs:fc:cn-hangzhou:118609547428****:services/fw1.LATEST/functions/log1

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 about error codes, see Error codes.	Success
Data	object	The event stream list.
EventStreamings	array<object>	The event stream list.
	array<object>	The event stream entity.
Description	string	The description of the event stream.	demo
EventStreamingName	string	The name of the event stream.	name
FilterPattern	string	The event filtering rule. If not specified, all events are matched.
Metadata	string
RunOptions	object	The runtime parameters.
BatchWindow	object	The batching 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, a push is triggered when any window meets the condition.	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, a push is triggered when any window meets the condition.	10
BusinessOption	object
BusinessMode	string
MaxCapacityUnitCount	integer
MinCapacityUnitCount	integer
DeadLetterQueue	object	Indicates whether the dead-letter queue is enabled. By default, the dead-letter queue is disabled, and messages that exceed the retry policy are discarded.
Arn	string	The Alibaba Cloud Resource Name (ARN) of the dead-letter queue.	acs:ram::159787121179****:role/aliyunsaedefaultrole
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 faults).	ALL
MaximumTasks	integer	The concurrency.	2
RetryStrategy	object	The retry policy when event pushing fails.
PushRetryStrategy	string	The retry policy. Valid values: BACKOFF_RETRY (backoff retry) and EXPONENTIAL_DECAY_RETRY (exponential decay retry).	EXPONENTIAL_DECAY_RETRY
Throttling	integer
Sink	object	The event target.
SinkAgentRunParameters	SinkAgentRunParameters
SinkApacheRocketMQCheckpointParameters	object	The Sink Apache RocketMQ Checkpoint parameters.
ConsumeTimestamp	object	The consumption checkpoint.
Form	string	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	The template style.
Value	string	The timestamp.	1636597951964
Group	object	The consumer group information of Apache RocketMQ.
Form	string	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	The template style.
Value	string	The Group ID of the consumer group.	GID_******
InstanceEndpoint	string	The endpoint of the Apache RocketMQ instance.	192.168.1.1:9876
InstancePassword	string	The password of the Apache RocketMQ instance.	****
InstanceUsername	string	The username of the Apache RocketMQ instance.	admin
NetworkType	string	The network type.	PrivateNetwork
SecurityGroupId	string	The security group ID.	sg-2vcgdxz7o1n9zapp****
Topic	object	The topic name of the Apache RocketMQ instance.
Form	string	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	The template style.
Value	string	The name of the topic.	myTopic
VSwitchId	string	The vSwitch ID.	vsw-wz9qqeovkwjxlu9uc****
VpcId	string	VPC ID。	vpc-2zehizpoendb3****
SinkApiDestinationParameters	SinkApiDestinationParameters	The ApiDestination target parameters.
SinkBaiLianParameters	SinkBaiLianParameters	The 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=rb8q3OpV2i3gZJ"
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-34b4f6fb2b71
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 definition 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 DashVector database operation type.	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: the content extracted by JSONPath. Note: The Value field cannot exceed 10,240 characters.	default
PrimaryKeyId	object	The primary key ID for 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: the content extracted by JSONPath. If Form is set to TEMPLATE: the 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 content extracted by JSONPath. Note: The Value field cannot exceed 10,240 characters.	$.data.messageBody
SinkDataHubParameters	object	The Sink DataHub parameters.
Body	object	The BLOB type. The record content template.
Form	string	The transformation format.	ORIGINAL
Template	string	None.
Value	string	The BLOB type. The record content template.
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	To grant authorization to the event bus EventBridge to use this role to read Simple Log Service (SLS) log content, the following conditions must be met: when you create the role used by the service in the Resource Access Management (RAM) console, set the trusted entity type to "Alibaba Cloud Service" and set the trusted service to "event bus".
Form	string	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	None.
Value	string	To grant authorization to the event bus EventBridge to use this role to read Simple Log Service (SLS) log content, the following conditions must be met: when you create the role used by the service in the Resource Access Management (RAM) console, set the trusted entity type to "Alibaba Cloud Service" and set the trusted service to "event bus".	testRole
Topic	object	The name of the DataHub topic.
Form	string	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	None.
Value	string	The name of the DataHub topic.	demo-topic
TopicSchema	object	The content schema of the topic. This parameter applies to the TUPLE type.
Form	string	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	None.
Value	string	The content schema of the topic. This parameter applies to the TUPLE type.	{"k1":"value1","k2":"value2"}
TopicType	object	The type of the topic. Valid values: TUPLE BLOB
Form	string	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	None.
Value	string	The type of the topic. Valid values: TUPLE BLOB	TUPLE
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
SinkEventHouseParameters	object	The event target name.
CatalogName	string	The catalog name.	cat1
EventTableName	string	The table name.	table1
MappingRules	array<object>	The field mapping rules.
	array<object>	The mapping rule.
ColumnName	string	The column name.	age
ColumnType	string	The column type.	text
ColumnValue	object	The column value extraction rule.
Form	string	The extraction method.	JSONPATH
Template	string	The template.	The value of ${key} is ${value}!
Value	string	The extraction path.	$.data.value
NamespaceName	string	The namespace name.	name1
SinkFcParameters	object	The function target.
Body	object	The content body sent to the function.
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" }
Concurrency	object	The delivery concurrency. The minimum value is 1.
Form	string	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	None.
Value	string	The delivery concurrency. The minimum value is 1.	1
DataFormat	object	The transformation rule for the event content format.
Form	string	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	The template style.	The value of ${key} is ${value}!
Value	string	The value before transformation.	{ "key": "value" }
FunctionName	object	The function name.
Form	string	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	None.
Value	string	The function name.	mFunction
InvocationType	object	The invocation type. Valid values: Sync: synchronous. Async: asynchronous.
Form	string	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	None.
Value	string	The invocation type. Valid values: Sync: synchronous. Async: asynchronous.	Async
Qualifier	object	The alias of the service to which the function belongs.
Form	string	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	None.
Value	string	The alias of the service to which the function belongs.	LATEST
ServiceName	object	The name of the service.
Form	string	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	None.
Value	string	The name of the service.	myService
SinkFnfParameters	object	The Sink Fnf parameters.
ExecutionName	object	The execution name.
Form	string	The transformation format. Default value: CONSTANT.	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 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 delivers high performance but has a high risk of data loss. acks=1: A response is returned after the primary node on the server successfully writes the data. This mode delivers moderate performance and has 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 successfully writes the data and the secondary nodes complete synchronization. This mode delivers lower performance but provides 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	None.
Value	string	The acknowledgment mode for writing to Kafka: acks=0: No response is required from the server. This mode delivers high performance but has a high risk of data loss. acks=1: A response is returned after the primary node on the server successfully writes the data. This mode delivers moderate performance and has 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 successfully writes the data and the secondary nodes complete synchronization. This mode delivers lower performance but provides higher data safety. Data loss occurs only if both the primary and secondary nodes go down.	1
CompressionType	string
DynamicTopic	object	The target topic strategy for message routing. If both the topic parameter and the topics parameter are specified, the value of the topics parameter takes precedence. The following two configuration modes are supported: 1. Static constant mode: Enter a fixed topic name string (for example, "order_created"). All messages are sent to this topic. 2. Dynamic extraction mode: Enter 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. CONSTANT: a constant. JSONPATH: extracts a value from the upstream source based on a path.
Template	string	The template.
Value	string	The value.
InstanceId	object	The target service type is MSMQ for Apache Kafka.
Form	string	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	None.
Value	string	The instance ID.	Defaut_1283278472_sad****
Key	object	The message key.
Form	string	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	None.
Value	string	The message key.	key
Topic	object	The topic name.
Form	string	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	None.
Value	string	The topic name.	topic
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 target parameters for delivering event streams to an EventHouse knowledge base. Specify this parameter only when the sink type is knowledge base.
SinkMNSParameters	object	The Simple MSMQ (formerly MNS) event target.
Body	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" }
IsBase64Encode	object	Indicates whether Base64 encoding is enabled.
Form	string	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	None.
Value	string	Indicates whether Base64 encoding is enabled.	true
QueueName	object	The target service type is Simple MSMQ (formerly MNS).
Form	string	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	None.
Value	string	The name of the Simple MSMQ (formerly MNS) queue.	MyQueue
SinkMQTTParameters	SinkMQTTParameters
SinkOSSParameters	SinkOSSParameters
SinkOpenSourceRabbitMQParameters	object	The sink open-source RabbitMQ parameters.
AuthType	string	The authentication type.	ACL
Body	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" }
Endpoint	string	The RabbitMQ instance endpoint.	192.168.1.1:9876
Exchange	string	The name of the exchange used for message routing.	my_exchange
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" }
NetworkType	string	The network type.	PrivateNetwork
Password	string	The username and password used for identity verification.	****
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	string	The name of the queue used to store messages.	my_queue
RoutingKey	object	The routing rule of the message. This parameter is required only when the TargetType parameter is set to Exchange.
Form	string	The data format. Default value: JSONPATH.	JSONPATH
Template	string	The template style.	The value of ${key} is ${value}!
Value	string	The routing rule of the message.	housekeeping
SecurityGroupId	string	The security group ID.	sg-2vcgdxz7o1n9zapp****
TargetType	string	The target type.	exchange
Username	string	The username used for authentication.	admin
VSwitchIds	string	The vSwitch ID.	vsw-wz9qqeovkwjxlu9uc****
VirtualHostName	string	The virtual host name of RabbitMQ.	Vhost1
VpcId	string	VPC ID。	vpc-2zehizpoendb3****
SinkRabbitMQMetaParameters	SinkRabbitMQMetaParameters
SinkRabbitMQMsgSyncParameters	SinkRabbitMQMsgSyncParameters
SinkRabbitMQParameters	object	The parameters for the sink RabbitMQ.
Body	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" }
Exchange	object	The Exchange mode. This parameter is required only when the TargetType parameter is set to Exchange.
Form	string	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	None.
Value	string	The name of the Exchange on 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	None.
Value	string	The instance ID of ApsaraMQ for RabbitMQ.	si-296cd57939a1421b****
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 the TargetType parameter is set to Queue.
Form	string	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	None.
Value	string	The name of the Queue on the instance.	MyQueue
RoutingKey	object	The routing rule for messages. This parameter is required only when the TargetType parameter is set to Exchange.
Form	string	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	None.
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	None.
Value	string	The target type. Valid values: Exchange: Exchange mode. Queue: Queue mode.	Queue
VirtualHostName	object	The name of the Vhost on the ApsaraMQ for RabbitMQ instance.
Form	string	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	None.
Value	string	The name of the Vhost on the ApsaraMQ for RabbitMQ instance.	rabbit-host
SinkRocketMQCheckpointParameters	object	The parameters for the sink RocketMQ checkpoint.
ConsumeTimestamp	object	The consumption checkpoint.
Form	string	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	The template style.
Value	string	The timestamp.	1636597951964
Group	object	The consumer group information of ApsaraMQ for RocketMQ.
Form	string	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	The template style.
Value	string	The Group ID of the consumer group.	GID_******
InstanceId	string	The instance ID of ApsaraMQ for RocketMQ.	MQ_INST_1825725063814405_BZ******
InstanceType	string	The instance type of ApsaraMQ for RocketMQ.	Cloud_5
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.	myTopic
SinkRocketMQParameters	object	The parameters for the sink RocketMQ source.
Body	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" }
DeliveryOrderType	object	The delivery order type of messages.
Form	string	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	None.
Value	string	The delivery order type.	Orderly
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	None.
Value	string	The instance ID of ApsaraMQ for RocketMQ.	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.
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, which is used to control message partitioning.
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 MSMQ for RocketMQ instance.
Form	string	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	None.
Value	string	The topic of the MSMQ for RocketMQ instance.	topic
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 VPC ID.
Form	string	The format of the event transformation. Default value: CONSTANT.	CONSTANT
Template	string	None.
Value	string	The VPC ID.	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 custom log key-value pairs. 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 transformation format. Default value: CONSTANT.	CONSTANT
Template	string	None.
Value	string	The value before transformation.	{"Key_1":{"form":"CONSTANT","value":"demoKey"},"Value_1":{"form":"JSONPATH","value":"$.data.value"}}
ContentType	object	The SLS data format. You can use the default format or specify key-value pairs. Valid values: JSON KeyValue
Form	string	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	None.
Value	string	The SLS data format. You can use the default format or specify key-value pairs. Valid values: JSON KeyValue	JSON
LogStore	object	The Logstore of Simple Log Service (SLS).
Form	string	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	None.
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	None.
Value	string	The project of Simple Log Service (SLS).	test-project
RoleName	object	The role used for authorization of EventBridge to read SLS log content. To use this role, the following conditions must be met: when you create the role used by the service in the Resource Access Management (RAM) console, select Alibaba Cloud Service, and set the trusted service to EventBridge.
Form	string	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	None.
Value	string	The role used for authorization of EventBridge to read SLS log content. To use this role, the following conditions must be met: when you create the role used by the service in the Resource Access Management (RAM) console, select Alibaba Cloud Service, and set the trusted service to EventBridge.	test-role
Topic	object	The topic of the log, which corresponds to the SLS reserved field "topic".
Form	string	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	None.
Value	string	The topic of the log, which corresponds to the SLS reserved field "topic".	topic
Source	object	The event source.
SourceApacheRocketMQCheckpointParameters	object	The Source RocketMQ checkpoint parameters.
InstanceEndpoint	string	The endpoint of the Apache RocketMQ instance.	192.168.1.1:9876
InstancePassword	string	The password of the Apache RocketMQ instance.	****
InstanceUsername	string	The username of the Apache RocketMQ 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 topic of the Apache RocketMQ instance.
	string	The topic of the Apache RocketMQ instance.	myTopic
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 Kafka 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.	gtm-cn-k2c2yfg****
SourceDTSParameters	object	The Source DTS event source.
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.	123456
Sid	string	The consumer group ID.	HG9
TaskId	string	The task ID.	1611b337285f44e2936a2c4170****
Topic	string	The subscribed topic of the data subscription channel.	TP_TEST_UNDERWRITE_ISSUE
Username	string	The username of the consumer group account.	admin
SourceEventBusParameters	object	The Source event bus event source.
EventBusName	string	The event bus name.	my-event-bus
EventRuleName	string	The event rule name.	my-event-rule
SourceFeiShuDocsParameters	SourceFeiShuDocsParameters
SourceJDBCParameters	SourceJDBCParameters
SourceKafkaParameters	object	The Source Kafka event source.
ConsumerGroup	string	The group ID of the consumer that subscribes to the topic.	GID_TEST
InstanceId	string	The instance ID.	bastionhost-cn-i7m2gwt****
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-chengdu
SecurityGroupId	string	The security group ID.	sg-5ud5f3p0rqqis69****eho7cp
Topic	string	The topic name.	topic_empower_1642473600414
VSwitchIds	string	The vSwitch ID.	vsw-bp1rmi8rind7eo50c****
ValueDataType	string	The encoding and decoding format of the message body. Valid values: JSON Text Binary	JSON
VpcId	string	The VPC ID.	vpc-wz9ki1qdlx3cx5cbf****
SourceMNSParameters	object	The Source Simple Message Queue (formerly MNS) message event source.
IsBase64Decode	boolean	Indicates whether Base64 encoding is enabled.	true
QueueName	string	The name of the Simple Message Queue (formerly MNS) message queue.	work4
RegionId	string	The region ID.	cn-zhangjiakou
SourceMQTTParameters	object	The Source MQTT event source.
BodyDataType	string	The encoding format of the message. Valid values: JSON Text Binary	JSON
InstanceId	string	The instance ID.	bastionhost-cn-zvp27kc****
NetworkType	string	The network type.
RegionId	string	The region ID.	cn-qingdao
SecurityGroupId	string	The security group ID.
Topic	string	The topic name.	migration_instance
VSwitchIds	string	The vSwitch ID.
VpcId	string	VPC ID。
SourceMySQLParameters	SourceMySQLParameters	The Source MySQL event source.
SourceOSSParameters	object	The Source OSS event source.
BucketName	string	The name of the 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/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 event source.
AuthType	string	The authentication type.	ACL
BodyDataType	string	The message body data type.	Json
Endpoint	string	The instance endpoint.	192.168.1.1:9876
NetworkType	string	The network type.	PrivateNetwork
Password	string	The password used to connect to the open source RabbitMQ instance.	****
QueueName	string	The queue name of the open source RabbitMQ instance.	demo
SecurityGroupId	string	The security group ID.	sg-m5edtu24f12345****
Username	string	The username used to connect to the open source RabbitMQ instance.	admin
VSwitchIds	string	The vSwitch ID.	vsw-m5ev8asdc6h12345****
VirtualHostName	string	The virtual host name of the open source RabbitMQ instance.	Vhost1
VpcId	string	VPC ID。	vpc-m5e3sv4b12345****
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 custom labels attached to the event.	{"source":"prometheus-prod"}
Labels	string	The tag.	__name__=.*
RegionId	string	The region ID.	cn-beijing
RoleName	string	The role used to access Prometheus data.	testRole
SourceRabbitMQMetaParameters	SourceRabbitMQMetaParameters
SourceRabbitMQMsgSyncParameters	SourceRabbitMQMsgSyncParameters
SourceRabbitMQParameters	object	The Source RabbitMQ event source.
InstanceId	string	The instance ID of the ApsaraMQ for RabbitMQ instance.	dbaudit-cn-7mz2hqo****
QueueName	string	The queue name of the ApsaraMQ for RabbitMQ instance.	liuyang
RegionId	string	The region ID.	cn-zhangjiakou
VirtualHostName	string	The vhost name of the ApsaraMQ for RabbitMQ instance.	eb-connect
SourceRocketMQCheckpointParameters	object	The Source RocketMQ checkpoint parameters.
InstanceId	string	The instance ID of the ApsaraMQ for RocketMQ instance.	rmq-cn-jte3w******
InstanceType	string	The type of the ApsaraMQ for RocketMQ instance.	Cloud_5
RegionId	string	The region ID.	cn-hangzhou
Topics	array	The topic of the ApsaraMQ for RocketMQ instance.
	string	The topic of the ApsaraMQ for RocketMQ instance.	myTopic
SourceRocketMQParameters	object	The parameters that are returned if the event source is ApsaraMQ for RocketMQ.
AuthType	string	The authentication type.	ACL
BodyDataType	string	The encoding format of the message. 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.	registry-vpc.cn-hangzhou.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.	123
InstanceSecurityGroupId	string	The security group ID 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.	admin**
InstanceVSwitchIds	string	The vSwitch information of the instance.	vsw-m5ev8asdc6h123456****
InstanceVpcId	string	The ID of the virtual private cloud (VPC).	vpc-bp1a4gmlk31hy***l3ss
Network	string	The network type. Valid values: PublicNetwork PrivateNetwork	PublicNetwork
Offset	string	The consumption offset of the message. Valid values: CONSUMEFROMLASTOFFSET: Consumption starts from the latest offset. CONSUMEFROMFIRSTOFFSET: Consumption starts from the earliest offset. CONSUMEFROMTIMESTAMP: Consumption starts from the offset of the specified point in time.	CONSUMEFROMTIMESTAMP
RegionId	string	The region ID of the ApsaraMQ for RocketMQ instance.	cn-chengdu
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 if the Offset parameter is set to CONSUMEFROMTIMESTAMP.	1670742074043
Topic	string	The topic of the message.	topic_add_anima
VSwitchIds	string	The vSwitch ID.	vsw-m5ev8asdc6h12345****
VpcId	string	The VPC ID.	vpc-m5e3sv4b12345****
SourceSLSParameters	object	The parameters that are returned if the event source is Simple Log Service.
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 group ID of the consumer that subscribes to the topic.	go-dts-shelf-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 name for authorization of the event bus EventBridge to read Simple Log Service log content. To use this role, create a role in the Resource Access Management (RAM) console, select "Alibaba Cloud Service" as the trusted entity, and select "event bus" as the trusted service.	testRole
Status	string	The status of the event stream.	RUNNING
Transforms	array<object>	The event transformer configurations.
	object	The Alibaba Cloud Resource Name (ARN) of the cloud service, 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 emotion 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 service, 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
NextToken	string	Indicates whether there is more data to return. A value of empty string indicates that all data has been returned. If the value is not empty, set this value to the NextToken request parameter in the next call.	177
Total	integer	The total number of records.	10
Message	string	The error message.	The event streaming [xxxx] not existed!
RequestId	string	The request ID.	283FF852-C4B8-58C9-9777-F88A5A16****
Success	boolean	Indicates whether the operation was successful. The value true is returned if the operation was successful.	true

Examples

Success response

JSON format

{
  "Code": "Success",
  "Data": {
    "EventStreamings": [
      {
        "Description": "demo",
        "EventStreamingName": "name",
        "FilterPattern": "",
        "Metadata": "",
        "RunOptions": {
          "BatchWindow": {
            "CountBasedWindow": 100,
            "TimeBasedWindow": 10
          },
          "BusinessOption": {
            "BusinessMode": "",
            "MaxCapacityUnitCount": 0,
            "MinCapacityUnitCount": 0
          },
          "DeadLetterQueue": {
            "Arn": "acs:ram::159787121179****:role/aliyunsaedefaultrole",
            "Network": "PrivateNetwork",
            "SecurityGroupId": "sg-2vcgdxz7o1n9zapp****",
            "VSwitchIds": "vsw-m5ev8asdc6h12345****",
            "VpcId": "vpc-2zehizpoendb3****"
          },
          "ErrorsTolerance": "ALL",
          "MaximumTasks": 2,
          "RetryStrategy": {
            "PushRetryStrategy": "EXPONENTIAL_DECAY_RETRY"
          },
          "Throttling": 0
        },
        "Sink": {
          "SinkAgentRunParameters": {
            "AgentRuntimeName": "",
            "EndpointName": "",
            "RoleName": "",
            "Body": {
              "Value": "",
              "Form": "",
              "Template": ""
            },
            "Timeout": ""
          },
          "SinkApacheRocketMQCheckpointParameters": {
            "ConsumeTimestamp": {
              "Form": "CONSTANT",
              "Template": "",
              "Value": "1636597951964"
            },
            "Group": {
              "Form": "CONSTANT",
              "Template": "",
              "Value": "GID_******"
            },
            "InstanceEndpoint": "192.168.1.1:9876",
            "InstancePassword": "****",
            "InstanceUsername": "admin",
            "NetworkType": "PrivateNetwork",
            "SecurityGroupId": "sg-2vcgdxz7o1n9zapp****",
            "Topic": {
              "Form": "CONSTANT",
              "Template": "",
              "Value": "myTopic"
            },
            "VSwitchId": "vsw-wz9qqeovkwjxlu9uc****",
            "VpcId": "vpc-2zehizpoendb3****"
          },
          "SinkApiDestinationParameters": {
            "Name": "",
            "HeaderParameters": {
              "Form": "",
              "Value": "",
              "Template": ""
            },
            "BodyParameters": {
              "Form": "",
              "Value": "",
              "Template": ""
            },
            "QueryStringParameters": {
              "Form": "",
              "Value": "",
              "Template": ""
            },
            "Timeout": 0
          },
          "SinkBaiLianParameters": {
            "WorkspaceId": "",
            "ApplicationType": "",
            "Before": {
              "Form": "",
              "Value": "",
              "Template": ""
            },
            "After": {
              "Form": "",
              "Value": "",
              "Template": ""
            },
            "Context": "",
            "Extend": "",
            "Op": {
              "Form": "",
              "Value": "",
              "Template": ""
            },
            "Partition": {
              "Form": "",
              "Value": "",
              "Template": ""
            },
            "Offset": {
              "Form": "",
              "Value": "",
              "Template": ""
            }
          },
          "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=rb8q3OpV2i3gZJ\"",
            "ConnectorParameters": {
              "Config": {
                "connector.class": "com.mongodb.kafka.connect.MongoSinkConnector",
                "tasks.max": "1",
                "topics": "sourceA,sourceB"
              },
              "Name": "mongo-sink\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"
            }
          },
          "SinkCustomizedKafkaParameters": {
            "InstanceId": "90be1f96-4229-4535-bb76-34b4f6fb2b71\n"
          },
          "SinkDashVectorParameters": {
            "ApiKey": "Q34nExQH7sQ****\n",
            "Collection": "collection1\n",
            "DashVectorSchemaParameters": [
              {
                "Name": {
                  "Form": "",
                  "Template": "",
                  "Value": ""
                },
                "Type": {
                  "Form": "",
                  "Template": "",
                  "Value": ""
                },
                "Value": {
                  "Form": "",
                  "Template": "",
                  "Value": ""
                }
              }
            ],
            "InstanceId": "vrs-cn-lbj3ru1***\n",
            "Network": "PublicNetwork\n",
            "Operation": "Upsert\n",
            "Partition": {
              "Form": "CONSTANT\n",
              "Template": "",
              "Value": "default\n"
            },
            "PrimaryKeyId": {
              "Form": "JSONPATH\n",
              "Template": "${ID}\n",
              "Value": "$.data.requestId\n"
            },
            "Vector": {
              "Form": "JSONPATH\n",
              "Template": "",
              "Value": "$.data.messageBody\n"
            }
          },
          "SinkDataHubParameters": {
            "Body": {
              "Form": "ORIGINAL\n",
              "Template": "",
              "Value": ""
            },
            "Project": {
              "Form": "CONSTANT\n",
              "Template": "",
              "Value": "demo-project\n"
            },
            "RoleName": {
              "Form": "CONSTANT\n",
              "Template": "",
              "Value": "testRole\n"
            },
            "Topic": {
              "Form": "CONSTANT\n",
              "Template": "",
              "Value": "demo-topic\n"
            },
            "TopicSchema": {
              "Form": "CONSTANT",
              "Template": "",
              "Value": "{\"k1\":\"value1\",\"k2\":\"value2\"}\n"
            },
            "TopicType": {
              "Form": "CONSTANT\n",
              "Template": "",
              "Value": "TUPLE\n"
            }
          },
          "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": ""
            }
          },
          "SinkEventHouseParameters": {
            "CatalogName": "cat1",
            "EventTableName": "table1",
            "MappingRules": [
              {
                "ColumnName": "age",
                "ColumnType": "text",
                "ColumnValue": {
                  "Form": "JSONPATH",
                  "Template": "The value of ${key} is ${value}!",
                  "Value": "$.data.value"
                }
              }
            ],
            "NamespaceName": "name1"
          },
          "SinkFcParameters": {
            "Body": {
              "Form": "TEMPLATE",
              "Template": "The value of ${key} is ${value}!\n",
              "Value": "{\n      \"key\": \"value\"\n}"
            },
            "Concurrency": {
              "Form": "CONSTANT",
              "Template": "",
              "Value": "1"
            },
            "DataFormat": {
              "Form": "CONSTANT",
              "Template": "The value of ${key} is ${value}!\n",
              "Value": "{\n      \"key\": \"value\"\n}"
            },
            "FunctionName": {
              "Form": "CONSTANT",
              "Template": "",
              "Value": "mFunction"
            },
            "InvocationType": {
              "Form": "CONSTANT",
              "Template": "",
              "Value": "Async"
            },
            "Qualifier": {
              "Form": "CONSTANT",
              "Template": "",
              "Value": "LATEST"
            },
            "ServiceName": {
              "Form": "CONSTANT",
              "Template": "",
              "Value": "myService"
            }
          },
          "SinkFnfParameters": {
            "ExecutionName": {
              "Form": "CONSTANT",
              "Template": "",
              "Value": "123"
            },
            "FlowName": {
              "Form": "CONSTANT",
              "Template": "",
              "Value": "test-streaming-fnf\n"
            },
            "Input": {
              "Form": "CONSTANT",
              "Template": "",
              "Value": "123"
            },
            "RoleName": {
              "Form": "CONSTANT",
              "Template": "",
              "Value": "Al****FNF-x****\n"
            }
          },
          "SinkHttpsParameters": {
            "URL": {
              "Form": "",
              "Value": "",
              "Template": ""
            },
            "Method": "",
            "Body": {
              "Form": "",
              "Value": "",
              "Template": ""
            },
            "Token": "",
            "NetworkType": "",
            "VpcId": "",
            "VSwitchIds": "",
            "SecurityGroupId": ""
          },
          "SinkKafkaParameters": {
            "Acks": {
              "Form": "CONSTANT",
              "Template": "",
              "Value": "1"
            },
            "CompressionType": "",
            "DynamicTopic": {
              "Form": "",
              "Template": "",
              "Value": ""
            },
            "InstanceId": {
              "Form": "CONSTANT",
              "Template": "",
              "Value": "Defaut_1283278472_sad****"
            },
            "Key": {
              "Form": "CONSTANT",
              "Template": "",
              "Value": "key"
            },
            "Topic": {
              "Form": "CONSTANT",
              "Template": "",
              "Value": "topic"
            },
            "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}!\n",
              "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": false,
            "ContentTransform": {
              "Form": "",
              "Value": "",
              "Template": ""
            }
          },
          "SinkOpenSourceRabbitMQParameters": {
            "AuthType": "ACL",
            "Body": {
              "Form": "TEMPLATE\n",
              "Template": "The value of ${key} is ${value}!\n",
              "Value": "{\n      \"key\": \"value\"\n}"
            },
            "Endpoint": "192.168.1.1:9876",
            "Exchange": "my_exchange",
            "MessageId": {
              "Form": "TEMPLATE\n",
              "Template": "The value of ${key} is ${value}!",
              "Value": "{\n      \"key\": \"value\"\n}"
            },
            "NetworkType": "PrivateNetwork",
            "Password": "****",
            "Properties": {
              "Form": "TEMPLATE",
              "Template": "The value of ${key} is ${value}!",
              "Value": "\t\n{\n      \"key\": \"value\"\n}"
            },
            "QueueName": "my_queue",
            "RoutingKey": {
              "Form": "JSONPATH",
              "Template": "The value of ${key} is ${value}!\n",
              "Value": "housekeeping\n"
            },
            "SecurityGroupId": "sg-2vcgdxz7o1n9zapp****",
            "TargetType": "exchange",
            "Username": "admin",
            "VSwitchIds": "vsw-wz9qqeovkwjxlu9uc****",
            "VirtualHostName": "Vhost1",
            "VpcId": "vpc-2zehizpoendb3****"
          },
          "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}!\n",
              "Value": "{\n      \"key\": \"value\"\n}"
            },
            "Exchange": {
              "Form": "CONSTANT",
              "Template": "",
              "Value": "a_exchange"
            },
            "InstanceId": {
              "Form": "CONSTANT",
              "Template": "",
              "Value": "si-296cd57939a1421b****"
            },
            "MessageId": {
              "Form": "TEMPLATE",
              "Template": "The value of ${key} is ${value}!\n",
              "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": "",
              "Value": "MyQueue"
            },
            "RoutingKey": {
              "Form": "CONSTANT",
              "Template": "",
              "Value": "housekeeping"
            },
            "TargetType": {
              "Form": "CONSTANT",
              "Template": "",
              "Value": "Queue"
            },
            "VirtualHostName": {
              "Form": "CONSTANT",
              "Template": "",
              "Value": "rabbit-host\n"
            }
          },
          "SinkRocketMQCheckpointParameters": {
            "ConsumeTimestamp": {
              "Form": "CONSTANT",
              "Template": "",
              "Value": "1636597951964"
            },
            "Group": {
              "Form": "CONSTANT",
              "Template": "",
              "Value": "GID_******"
            },
            "InstanceId": "MQ_INST_1825725063814405_BZ******",
            "InstanceType": "Cloud_5",
            "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": "Orderly"
            },
            "InstanceEndpoint": {
              "Form": "CONSTANT\n",
              "Template": "",
              "Value": "vbr-8vbsvkkbpf3vb0zef****\n"
            },
            "InstanceId": {
              "Form": "CONSTANT",
              "Template": "",
              "Value": "MQ_INST_164901546557****_BAAN****\n"
            },
            "InstancePassword": {
              "Form": "CONSTANT\n",
              "Template": "",
              "Value": "admin******\n"
            },
            "InstanceType": {
              "Form": "CONSTANT\n",
              "Template": "",
              "Value": "Cloud_4"
            },
            "InstanceUsername": {
              "Form": "CONSTANT\n",
              "Template": "",
              "Value": "admin\n"
            },
            "Keys": {
              "Form": "TEMPLATE",
              "Template": "The value of ${key} is ${value}!\n",
              "Value": "{\n      \"key\": \"value\"\n}"
            },
            "Network": {
              "Form": "CONSTANT\n",
              "Template": "",
              "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}!\n",
              "Value": "{\n      \"key\": \"value\"\n}"
            },
            "Topic": {
              "Form": "CONSTANT",
              "Template": "",
              "Value": "topic"
            },
            "VSwitchIds": {
              "Form": "CONSTANT\n\n",
              "Template": "",
              "Value": "vbr-8vb835n3zf9shwl****mp\n"
            },
            "VpcId": {
              "Form": "CONSTANT\n",
              "Template": "",
              "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",
              "Template": "",
              "Value": "JSON\n"
            },
            "LogStore": {
              "Form": "CONSTANT",
              "Template": "",
              "Value": "test-logstore\n"
            },
            "Project": {
              "Form": "CONSTANT",
              "Template": "",
              "Value": "test-project\n"
            },
            "RoleName": {
              "Form": "CONSTANT",
              "Template": "",
              "Value": "test-role"
            },
            "Topic": {
              "Form": "CONSTANT",
              "Template": "",
              "Value": "topic"
            }
          }
        },
        "Source": {
          "SourceApacheRocketMQCheckpointParameters": {
            "InstanceEndpoint": "192.168.1.1:9876",
            "InstancePassword": "****",
            "InstanceUsername": "admin",
            "NetworkType": "PrivateNetwork",
            "RegionId": "cn-hangzhou",
            "SecurityGroupId": "sg-mw43*****",
            "Topics": [
              "myTopic"
            ],
            "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": "gtm-cn-k2c2yfg****\n"
          },
          "SourceDTSParameters": {
            "BrokerUrl": "",
            "InitCheckPoint": "1620962769",
            "Password": "123456",
            "Sid": "HG9",
            "TaskId": "1611b337285f44e2936a2c4170****",
            "Topic": "TP_TEST_UNDERWRITE_ISSUE\n",
            "Username": "admin"
          },
          "SourceEventBusParameters": {
            "EventBusName": "my-event-bus",
            "EventRuleName": "my-event-rule"
          },
          "SourceFeiShuDocsParameters": {
            "AppId": "cli_a946c046xxxx",
            "AppSecret": "yO3hEYiSjkBVxxxx",
            "KnowledgeSpaceName": "Product Documentation Center",
            "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": "bastionhost-cn-i7m2gwt****",
            "Network": "Default",
            "OffsetReset": "latest",
            "RegionId": "cn-chengdu",
            "SecurityGroupId": "sg-5ud5f3p0rqqis69****eho7cp",
            "Topic": "topic_empower_1642473600414\n",
            "VSwitchIds": "vsw-bp1rmi8rind7eo50c****",
            "ValueDataType": "JSON\n",
            "VpcId": "vpc-wz9ki1qdlx3cx5cbf****"
          },
          "SourceMNSParameters": {
            "IsBase64Decode": true,
            "QueueName": "work4",
            "RegionId": "cn-zhangjiakou"
          },
          "SourceMQTTParameters": {
            "BodyDataType": "JSON\n",
            "InstanceId": "bastionhost-cn-zvp27kc****",
            "NetworkType": "",
            "RegionId": "cn-qingdao",
            "SecurityGroupId": "",
            "Topic": "migration_instance",
            "VSwitchIds": "",
            "VpcId": ""
          },
          "SourceMySQLParameters": {
            "RegionId": "",
            "HostName": "",
            "User": "",
            "Password": "",
            "DatabaseName": "",
            "TableNames": "",
            "NetworkType": "",
            "VpcId": "",
            "VSwitchIds": "",
            "SecurityGroupId": "",
            "Port": 0,
            "SnapshotMode": "",
            "IncludeSchemaChanges": ""
          },
          "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.1:9876",
            "NetworkType": "PrivateNetwork",
            "Password": "****",
            "QueueName": "demo",
            "SecurityGroupId": "sg-m5edtu24f12345****",
            "Username": "admin",
            "VSwitchIds": "vsw-m5ev8asdc6h12345****",
            "VirtualHostName": "Vhost1",
            "VpcId": "vpc-m5e3sv4b12345****"
          },
          "SourcePostgreSQLParameters": {
            "RegionId": "",
            "HostName": "",
            "Port": 0,
            "User": "",
            "Password": "",
            "DatabaseName": "",
            "SchemaName": "",
            "TableNames": "",
            "NetworkType": "",
            "VpcId": "",
            "VSwitchIds": "",
            "SecurityGroupId": "",
            "SnapshotMode": ""
          },
          "SourcePrometheusParameters": {
            "ClusterId": "c83555068b6******ad213f565f209\n",
            "DataType": "JSON\n",
            "ExternalLabels": "{\"source\":\"prometheus-prod\"}",
            "Labels": "__name__=.*\n",
            "RegionId": "cn-beijing",
            "RoleName": "testRole"
          },
          "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": "dbaudit-cn-7mz2hqo****",
            "QueueName": "liuyang",
            "RegionId": "cn-zhangjiakou",
            "VirtualHostName": "eb-connect\n"
          },
          "SourceRocketMQCheckpointParameters": {
            "InstanceId": "\nrmq-cn-jte3w******",
            "InstanceType": "Cloud_5",
            "RegionId": "cn-hangzhou",
            "Topics": [
              "myTopic"
            ]
          },
          "SourceRocketMQParameters": {
            "AuthType": "ACL",
            "BodyDataType": "JSON\n",
            "FilterSql": "index > 10\n",
            "FilterType": "Tag\n",
            "GroupID": "GID_group1",
            "InstanceEndpoint": "registry-vpc.cn-hangzhou.aliyuncs.com",
            "InstanceId": "i-f8zbher64dlm58pl****\n",
            "InstanceNetwork": "PublicNetwork",
            "InstancePassword": "123",
            "InstanceSecurityGroupId": "sg-m5edtu24f12345****\n",
            "InstanceType": "Cloud_4\n",
            "InstanceUsername": "admin**",
            "InstanceVSwitchIds": "vsw-m5ev8asdc6h123456****\n",
            "InstanceVpcId": "vpc-bp1a4gmlk31hy***l3ss",
            "Network": "PublicNetwork",
            "Offset": "CONSUMEFROMTIMESTAMP",
            "RegionId": "cn-chengdu",
            "SecurityGroupId": "sg-m5edtu24f12345****\n",
            "Tag": "v1",
            "Timestamp": 1670742074043,
            "Topic": "topic_add_anima",
            "VSwitchIds": "vsw-m5ev8asdc6h12345****\n",
            "VpcId": "vpc-m5e3sv4b12345****\n"
          },
          "SourceSLSParameters": {
            "ConsumePosition": "begin",
            "ConsumerGroup": "go-dts-shelf-group",
            "LogStore": "waf-logstore\n",
            "Project": "dmmzk",
            "RoleName": "testRole"
          }
        },
        "Status": "RUNNING",
        "Transforms": [
          {
            "AiChunkTransformParameters": {
              "ChunkingType": "recursive_character",
              "InputField": {
                "Form": "JSONPATH",
                "Value": "$.data.message"
              },
              "MaxOverlapSize": 10,
              "MaxSegmentSize": 1000,
              "StepName": "chunks",
              "Unpack": true
            },
            "AiClassifyTransformParameters": {
              "InputField": {
                "Form": "JSONPATH",
                "Value": "$.data.message"
              },
              "Instruction": "提到崩溃或异常时归为 bug，无法判断时归为 other",
              "Labels": [
                "bug"
              ],
              "OutputMode": "single",
              "StepName": "classify_result"
            },
            "AiEmbedTransformParameters": {
              "Dimension": 1024,
              "InputField": {
                "Form": "JSONPATH",
                "Value": "$.data.message"
              },
              "Model": "text-embedding-v4",
              "StepName": "embedding"
            },
            "AiExtractTransformParameters": {
              "ExtractSchema": "{\"type\":\"object\",\"properties\":{\"orderId\":{\"type\":\"string\"},\"amount\":{\"type\":\"number\"}}}",
              "StepName": "extract_result"
            },
            "AiFilterTransformParameters": {
              "Condition": "仅保留用户投诉或退款相关的内容",
              "OnMismatch": "discard",
              "StepName": "filter_result"
            },
            "AiPrepSearchTransformParameters": {
              "MaxChunkSize": 20,
              "StepName": "chunks"
            },
            "AiRedactTransformParameters": {
              "Entities": [
                "PHONE"
              ],
              "MaskChar": "*",
              "Mode": "mask",
              "StepName": "redact_result"
            },
            "AiSentimentAnalysisTransformParameters": {
              "Aspects": [
                "价格"
              ],
              "StepName": "sentiment"
            },
            "AiSummarizeTransformParameters": {
              "MaxLength": 200,
              "StepName": "summary"
            },
            "AiTranslateTransformParameters": {
              "SourceLanguage": "zh",
              "StepName": "translation",
              "TargetLanguage": "en"
            },
            "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": ""
                }
              ]
            }
          }
        ]
      }
    ],
    "NextToken": "177",
    "Total": 10
  },
  "Message": "The event streaming [xxxx] not existed!\n",
  "RequestId": "283FF852-C4B8-58C9-9777-F88A5A16****",
  "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.