All Products
Search
Document Center

EventBridge:GetEventStreaming

Last Updated:Dec 04, 2024

Queries the details of an event stream.

Operation description

You can call this API operation to query the details of an event stream.

Debugging

You can run this interface directly in OpenAPI Explorer, saving you the trouble of calculating signatures. After running successfully, OpenAPI Explorer can automatically generate SDK code samples.

Authorization information

The following table shows the authorization information corresponding to the API. The authorization information can be used in the Action policy element to grant a RAM user or RAM role the permissions to call this API operation. Description:

  • Operation: the value that you can use in the Action element to specify the operation on a resource.
  • Access level: the access level of each operation. The levels are read, write, and list.
  • Resource type: the type of the resource on which you can authorize the RAM user or the RAM role to perform the operation. Take note of the following items:
    • The required resource types are displayed in bold characters.
    • If the permissions cannot be granted at the resource level, All Resources is used in the Resource type column of the operation.
  • Condition Key: the condition key that is defined by the cloud service.
  • Associated operation: other operations that the RAM user or the RAM role must have permissions to perform to complete the operation. To complete the operation, the RAM user or the RAM role must have the permissions to perform the associated operations.
OperationAccess levelResource typeCondition keyAssociated operation
eventbridge:GetEventStreamingget
*EventStreaming
acs:eventbridge:{#regionId}:{#accountId}:eventstreaming/{#EventStreamingName}
    none
none

Request parameters

ParameterTypeRequiredDescriptionExample
EventStreamingNamestringYes

The name of the event stream whose details you want to query.

myeventstreaming

Response parameters

ParameterTypeDescriptionExample
object
Messagestring

The error message that is returned if the request failed.

The event streaming [xxxx] not existed!
RequestIdstring

The request ID.

7892F480-58C9-5067-AB35-8A7BEF0F726A
Dataobject

The returned data.

EventStreamingNamestring

The name of the event stream that is returned.

rocketmq-sync
Descriptionstring

The description of the event stream that is returned.

RocketMQ-to-RocketMQ
Sourceobject

The event provider, which is also known as the event source.

SourceMNSParametersobject

Source MNS Parameters

RegionIdstring

The region ID of the MNS queue.

cn-hangzhou
QueueNamestring

The name of the MNS queue.

demo
IsBase64Decodeboolean

Indicates whether Base64 encoding is enabled.

true
SourceRabbitMQParametersobject

Source RabbitMQ Parameters

RegionIdstring

The region ID of the Message Queue for RabbitMQ instance.

cn-hangzhou
InstanceIdstring

The ID of the Message Queue for RabbitMQ instance.

i-f8z9a9mcgwri1c1idd0z
VirtualHostNamestring

The vhost name of the Message Queue for RabbitMQ instance.

eb-connect
QueueNamestring

The name of the queue in the Message Queue for RabbitMQ instance.

comp
SourceRocketMQParametersobject

The parameters that are returned if ApsaraMQ for RocketMQ is specified as the event source.

RegionIdstring

The region ID of the Message Queue for Apache RocketMQ instance.

cn-hangzhou
InstanceIdstring

The ID of the Message Queue for Apache RocketMQ instance.

i-f8zbher64dlm58plyfte
Topicstring

The topic to which the message belongs.

topic_add_anima
Tagstring

The tags that are used to filter messages.

v1
Offsetstring

The consumer offset of messages. Valid values: CONSUME_FROM_LAST_OFFSET: Start consumption from the latest offset. CONSUME_FROM_FIRST_OFFSET: Start consumption from the earliest offset. CONSUME_FROM_TIMESTAMP: Start consumption from the offset at the specified point in time.

CONSUMEFROMLASTOFFSET
GroupIDstring

The ID of the consumer group in the Message Queue for Apache RocketMQ instance.

GID_group1
Timestamplong

The timestamp of the offset from which consumption starts. This parameter is valid only if you set the Offset parameter to CONSUME_FROM_TIMESTAMP.

1636597951964
SourceKafkaParametersobject

The parameters that are returned if ApsaraMQ for Kafka is specified as the event source.

RegionIdstring

The region ID of the Message Queue for Apache Kafka instance.

cn-hangzhou
InstanceIdstring

The instance ID.

i-bp1fbtrnqmjvgq66ajdw
Topicstring

The name of the topic.

topic_empower_1642473600414
ConsumerGroupstring

The ID of the consumer group that subscribes to the topic.

GID_TEST
OffsetResetstring

The offset.

latest
Networkstring

The network. Default value: Default. The value PublicNetwork specifies a virtual private cloud (VPC).

Default
VpcIdstring

The ID of the virtual private cloud (VPC).

vpc-2zehizpoendb3nwwu9w5o
VSwitchIdsstring

The vSwitch ID.

vsw-wz9qqeovkwjxlu9uc8rst
SecurityGroupIdstring

The security group ID.

sg-2vcgdxz7o1n9zappuimt
ValueDataTypestring

The encoding or decoding format. Valid values: Json, Text, and Binary. The value Json indicates that bytes are decoded into UTF-8 strings and then parsed into JSON format. The value Text indicates that bytes are decoded into UTF-8 strings and then put into the payload. The value Binary indicates that bytes are encoded into Base64 strings and put into the payload.

Text
SourceMQTTParametersobject

The parameters that are returned if ApsaraMQ for MQTT is specified as the event source.

RegionIdstring

The region ID of the Message Queue for MQTT instance.

cn-shanghai
InstanceIdstring

The instance ID.

i-2ze06wqdwk0uq14krrzv
Topicstring

The name of the topic in the Message Queue for MQTT instance.

TOPIC-cainiao-pcs-wms-instock-noPrealertPrintLabel
SourceDTSParametersobject

The parameters that are returned if the event source is Data Transmission Service (DTS).

TaskIdstring

The task ID.

f86e5814-b223-482c-b768-3b873297dade
BrokerUrlstring

The URL and port number of the data subscription channel.

Topicstring

The topic to which you want to subscribe by using the data subscription channel.

TP_TEST_UNDERWRITE_ISSUE
Sidstring

The ID of the consumer group.

HD1
Usernamestring

The account of the consumer group.

admin
Passwordstring

The password of the consumer group.

admin
InitCheckPointstring

The consumer offset. A consumer offset is a timestamp that indicates when the SDK client consumes the first data record. The value is a UNIX timestamp.

1620962769
SourceSLSParametersobject

The parameters that are returned if the event provider is Simple Log Service.

Projectstring

The Log Service project.

dmmzk
LogStorestring

The Log Service Logstore.

waf-logstore
ConsumerGroupstring

The consumer group.

ConsumePositionstring

The starting consumer offset. The value begin indicates the earliest offset, and the value end indicates the latest offset. You can also specify a time in seconds to start consumption.

begin
RoleNamestring

The role name. If you want to authorize EventBridge to use this role to read logs in Log Service, you must select Alibaba Cloud Service for Selected Trusted Entity and EventBridge for Select Trusted Service when you create the role in the RAM console.

testRole
FilterPatternstring

The rule that is used to filter events. If you leave this parameter empty, all events are matched.

Transformsarray<object>
Transformsobject
Arnstring

The Alibaba Cloud Resource Name (ARN) of the cloud service, such as the ARN of a Function Compute function.

acs:fc:cn-hangzhou:*****:services/demo-service.LATEST/functions/demo-func
Sinkobject

The event target.

SinkMNSParametersobject

The parameters that are returned if the event target is Message Service (MNS).

QueueNameobject

The target service type is MNS.

Valuestring

The name of the MNS queue.

MyQueue
Formstring

The method that is used to transform the event. Default value: CONSTANT.

CONSTANT
Templatestring

The template style.

Bodyobject

The message content.

Valuestring

The value before the transformation.

{ "key": "value" }
Formstring

The method that is used to transform the event.

TEMPLATE
Templatestring

The template based on which the event is transformed.

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

Indicates whether Base64 encoding is enabled.

Valuestring

Specifies that Base64 encoding is enabled.

true
Formstring

The method that is used to transform the event. Default value: CONSTANT.

CONSTANT
Templatestring

The template style.

SinkRabbitMQParametersobject

The parameters that are returned if the event target is Message Queue for RabbitMQ.

InstanceIdobject

The target service type is Message Queue for RabbitMQ instance.

Valuestring

The ID of the Message Queue for RabbitMQ instance.

e5c9b727-e06c-4d7e-84d5-f8ce644e00bf
Formstring

The method that is used to transform the event. Default value: CONSTANT.

CONSTANT
Templatestring

The template style.

VirtualHostNameobject

The name of the vhost of the Message Queue for RabbitMQ instance.

Valuestring

The vhost name of the Message Queue for RabbitMQ instance.

rabbit-host
Formstring

The method that is used to transform the event. Default value: CONSTANT.

CONSTANT
Templatestring

The template style.

TargetTypeobject

The target type.

Valuestring

The type of the resource to which the event is delivered. Valid values: Exchange: exchanges. Queue: queues.

Exchange/Queue
Formstring

The method that is used to transform the event. Default value: CONSTANT.

CONSTANT
Templatestring

The template style.

Exchangeobject

The exchange mode. This parameter is available only if TargetType is set to Exchange.

Valuestring

The name of the exchange in the Message Queue for RabbitMQ instance.

a_exchange
Formstring

The method that is used to transform the event. Default value: CONSTANT.

CONSTANT
Templatestring

The template style.

RoutingKeyobject

The routing rule for the message. This parameter is available only if TargetType is set to Exchange.

Valuestring

The routing rule for the message.

housekeeping
Formstring

The method that is used to transform the event. Default value: CONSTANT.

CONSTANT
Templatestring

The template style.

QueueNameobject

The queue mode. This parameter is available only if TargetType is set to Queue.

Valuestring

The name of the queue in the Message Queue for RabbitMQ instance.

MyQueue
Formstring

The method that is used to transform the event. Default value: CONSTANT.

CONSTANT
Templatestring

The template style.

Bodyobject

The message content.

Valuestring

The value before the transformation.

{ "key": "value" }
Formstring

The method that is used to transform the event.

TEMPLATE
Templatestring

The template based on which the event is transformed.

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

The message ID.

Valuestring

The value before the transformation.

{ "key": "value" }
Formstring

The method that is used to transform the event.

TEMPLATE
Templatestring

The template based on which the event is transformed.

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

The tags that are used to filter messages.

Valuestring

The value before the transformation.

{ "key": "value" }
Formstring

The method that is used to transform the event.

TEMPLATE
Templatestring

The template based on which the event is transformed.

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

The parameters that are returned if the event target is Function Compute.

ServiceNameobject

The service name.

Valuestring

The name of the service.

myService
Formstring

The method that is used to transform the event. Default value: CONSTANT.

CONSTANT
Templatestring

The template style.

FunctionNameobject

The function name.

Valuestring

The function name.

mFunction
Formstring

The method that is used to transform the event. Default value: CONSTANT.

CONSTANT
Templatestring

The template style.

Concurrencyobject

The delivery concurrency. Minimum value: 1.

Valuestring

The delivery concurrency. Minimum value: 1.

1
Formstring

The method that is used to transform the event. Default value: CONSTANT.

CONSTANT
Templatestring

The template style.

None
Qualifierobject

The alias of the service to which the function belongs.

Valuestring

The alias of the service to which the function belongs.

LATEST
Formstring

The method that is used to transform the event. Default value: CONSTANT.

CONSTANT
Templatestring

The template style.

InvocationTypeobject

The invocation type. Valid values: Sync: synchronous Async: asynchronous

Valuestring

The invocation type.

Async
Formstring

The method that is used to transform the event. Default value: CONSTANT.

CONSTANT
Templatestring

The template style.

Bodyobject

The message body that is sent to the function.

Valuestring

The value before the transformation.

{ "key": "value" }
Formstring

The method that is used to transform the event.

TEMPLATE
Templatestring

The template based on which the event is transformed.

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

The parameters that are returned if the event target is Message Queue for Apache Kafka.

InstanceIdobject

The target service type is Message Queue for Apache Kafka.

Valuestring

The instance ID.

Defaut_1283278472_sadkj
Formstring

The method that is used to transform the event. Default value: CONSTANT.

CONSTANT
Templatestring

The template style.

Topicobject

The topic name.

Valuestring

The topic name.

topic-test
Formstring

The method that is used to transform the event. Default value: CONSTANT.

CONSTANT
Templatestring

The template style.

Acksobject

The acknowledgment information.

Valuestring

The acknowledgment information.

1
Formstring

The method that is used to transform the event. Default value: CONSTANT.

CONSTANT
Templatestring

The template style.

Keyobject

The message key.

Valuestring

The message key.

key
Formstring

The method that is used to transform the event. Default value: CONSTANT.

CONSTANT
Templatestring

The template style.

Valueobject

The message content.

Valuestring

The value before the transformation.

{ "key": "value" }
Formstring

The method that is used to transform the event.

TEMPLATE
Templatestring

The template based on which the event is transformed.

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

The parameters that are returned if ApsaraMQ for RocketMQ is specified as the event target.

InstanceIdobject

The target service type is Message Queue for Apache RocketMQ.

Valuestring

The ID of the Message Queue for Apache RocketMQ instance.

MQ_INST_164901546557****_BAAN****
Formstring

The method that is used to transform the event. Default value: CONSTANT.

CONSTANT
Templatestring

The template style.

Topicobject

The name of the topic in the Message Queue for Apache RocketMQ instance.

Valuestring

The name of the topic in the Message Queue for Apache RocketMQ instance.

Mytopic
Formstring

The method that is used to transform the event. Default value: CONSTANT.

CONSTANT
Templatestring

The template style.

Bodyobject

The message content.

Valuestring

The value before the transformation.

{ "key": "value" }
Formstring

The method that is used to transform the event.

TEMPLATE
Templatestring

The template based on which the event is transformed.

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

The tags that are used to filter messages.

Valuestring

The value before the transformation.

{ "key": "value" }
Formstring

The method that is used to transform the event.

TEMPLATE
Templatestring

The template based on which the event is transformed.

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

The tags that are used to filter messages.

Valuestring

The value before the transformation.

{ "key": "value" }
Formstring

The method that is used to transform the event.

TEMPLATE
Templatestring

The template based on which the event is transformed.

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

The tags that are used to filter messages.

Valuestring

The value before the transformation.

{ "key": "value" }
Formstring

The method that is used to transform the event.

TEMPLATE
Templatestring

The template based on which the event is transformed.

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

The parameters that are returned if Simple Log Service is specified as the event target.

Projectobject

The Simple Log Service project.

Valuestring

The Log Service project.

test-project
Formstring

The method that is used to transform the event. Default value: CONSTANT.

CONSTANT
Templatestring

The template style.

LogStoreobject

The Simple Log Service Logstore.

Valuestring

The Log Service Logstore.

test-logstore
Formstring

The method that is used to transform the event. Default value: CONSTANT.

CONSTANT
Templatestring

The template style.

Topicobject

The name of the topic in which logs are stored. The topic corresponds to the topic reserved field in Simple Log Service.

Valuestring

The name of the topic in which logs are stored. The topic corresponds to the topic reserved field in Log Service.

testTopic
Formstring

The method that is used to transform the event. Default value: CONSTANT.

CONSTANT
Templatestring

The template style.

Bodyobject

The message content.

Valuestring

The value before the transformation.

{ "key": "value" }
Formstring

The method that is used to transform the event.

TEMPLATE
Templatestring

The template based on which the event is transformed.

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

The role name. If you want to authorize EventBridge to use this role to read logs in Simple Log Service, you must select Alibaba Cloud Service for Selected Trusted Entity and EventBridge for Select Trusted Service when you create the role in the Resource Access Management (RAM) console.

Valuestring

The role name. If you want to authorize EventBridge to use this role to read logs in Log Service, you must select Alibaba Cloud Service for Selected Trusted Entity and EventBridge for Select Trusted Service when you create the role in the RAM console.

testRole
Formstring

The method that is used to transform the event. Default value: CONSTANT.

CONSTANT
Templatestring

The template style.

SinkFnfParametersobject

The Sink Fnf parameters.

FlowNameobject

The flow name.

Valuestring

The flow name.

test-streaming-fnf
Formstring

The method that is used to transform events. Default value: CONSTANT.

CONSTANT
Templatestring

The template style.

None
ExecutionNameobject

The execution name.

Valuestring

The execution name.

123
Formstring

The method that is used to transform events. Default value: CONSTANT.

CONSTANT
Templatestring

The template style.

None
Inputobject

The execution input information.

Valuestring

The execution input information.

123
Formstring

The method that is used to transform events. Default value: CONSTANT.

CONSTANT
Templatestring

The template style.

None
RoleNameobject

The role name.

Valuestring

The role configuration.

Al****FNF-x****
Formstring

The method that is used to transform events. Default value: CONSTANT.

CONSTANT
Templatestring

The template style.

None
RunOptionsobject

The runtime environment-related configurations.

MaximumTasksinteger

The concurrency level.

2
RetryStrategyobject

The information about the retry policy that is used if the event fails to be pushed.

PushRetryStrategystring

The retry policy. Valid values: BACKOFFRETRY and EXPONENTIALDECAY_RETRY.

BACKOFFRETRY
MaximumEventAgeInSecondsfloat

The maximum period of time during which retries are performed.

512
MaximumRetryAttemptsfloat

The maximum number of retries.

2
ErrorsTolerancestring

The fault tolerance policy. The value NONE specifies that faults are not tolerated, and the value All specifies that all faults are tolerated.

ALL
DeadLetterQueueobject

Indicates whether dead-letter queues are enabled. By default, dead-letter queues are disabled. Messages that fail to be pushed after allowed retries as specified by the retry policy are discarded.

Arnstring

The Alibaba Cloud Resource Name (ARN) of the dead-letter queue.

acs:ram::1550203943326350:role/edskmstoecs
BatchWindowobject

The batch window.

CountBasedWindowinteger

The maximum number of events that are allowed in the batch window. If this threshold is reached, data in the window is pushed downstream. When multiple batch windows exist, data is pushed if triggering conditions are met in one of the windows.

100
TimeBasedWindowinteger

The maximum period of time during which events are allowed in the batch window. Unit: seconds. If this threshold is reached, data in the window is pushed downstream. When multiple batch windows exist, data is pushed if triggering conditions are met in one of the windows.

10
Statusstring

The status of the event stream that is returned.

RUNNING
Codestring

The response code. The value Success indicates that the request is successful. Other values indicate that the request failed. For a list of error codes, see Error codes.

Success
Successboolean

Indicates whether the operation is successful. The value true indicates that the operation is successful.

true

Examples

Sample success responses

JSONformat

{
  "Message": "The event streaming [xxxx] not existed!",
  "RequestId": "7892F480-58C9-5067-AB35-8A7BEF0F726A",
  "Data": {
    "EventStreamingName": "rocketmq-sync",
    "Description": "RocketMQ-to-RocketMQ",
    "Source": {
      "SourceMNSParameters": {
        "RegionId": "cn-hangzhou",
        "QueueName": "demo",
        "IsBase64Decode": true
      },
      "SourceRabbitMQParameters": {
        "RegionId": "cn-hangzhou",
        "InstanceId": "i-f8z9a9mcgwri1c1idd0z",
        "VirtualHostName": "eb-connect",
        "QueueName": "comp"
      },
      "SourceRocketMQParameters": {
        "RegionId": "cn-hangzhou",
        "InstanceId": "i-f8zbher64dlm58plyfte",
        "Topic": "topic_add_anima",
        "Tag": "v1",
        "Offset": "CONSUMEFROMLASTOFFSET",
        "GroupID": "GID_group1",
        "Timestamp": 1636597951964,
        "InstanceType": "2",
        "InstanceEndpoint": "reg****-vpc.cn-zhangjiakou.aliyuncs.com\n",
        "AuthType": "ACL",
        "InstanceUsername": "xxxa",
        "InstancePassword": "xxxa",
        "InstanceVpcId": "vpc-m5e3sv4b12345****\n",
        "InstanceVSwitchIds": "vsw-m5ev8asdc6h12****\n",
        "InstanceSecurityGroupId": "sg-m5edtu24f12345****\n",
        "InstanceNetwork": "PublicNetwork",
        "BodyDataType": "",
        "FilterType": "",
        "FilterSql": "",
        "VpcId": "",
        "VSwitchIds": "",
        "SecurityGroupId": "",
        "Network": ""
      },
      "SourceKafkaParameters": {
        "RegionId": "cn-hangzhou",
        "InstanceId": "i-bp1fbtrnqmjvgq66ajdw",
        "Topic": "topic_empower_1642473600414",
        "ConsumerGroup": "GID_TEST",
        "OffsetReset": "latest",
        "Network": "Default",
        "VpcId": "vpc-2zehizpoendb3nwwu9w5o",
        "VSwitchIds": "vsw-wz9qqeovkwjxlu9uc8rst",
        "SecurityGroupId": "sg-2vcgdxz7o1n9zappuimt",
        "ValueDataType": "Text"
      },
      "SourceMQTTParameters": {
        "RegionId": "cn-shanghai",
        "InstanceId": "i-2ze06wqdwk0uq14krrzv",
        "Topic": "TOPIC-cainiao-pcs-wms-instock-noPrealertPrintLabel",
        "BodyDataType": ""
      },
      "SourceDTSParameters": {
        "TaskId": "f86e5814-b223-482c-b768-3b873297dade",
        "BrokerUrl": "",
        "Topic": "TP_TEST_UNDERWRITE_ISSUE",
        "Sid": "HD1",
        "Username": "admin",
        "Password": "admin",
        "InitCheckPoint": "1620962769"
      },
      "SourceSLSParameters": {
        "Project": "dmmzk",
        "LogStore": "waf-logstore",
        "ConsumerGroup": "",
        "ConsumePosition": "begin",
        "RoleName": "testRole"
      },
      "SourcePrometheusParameters": {
        "RegionId": "",
        "ClusterId": "c83555068b6******ad213f565f209\n",
        "DataType": "json",
        "Labels": "__name__=.*\n"
      },
      "SourceCustomizedKafkaParameters": {
        "InstanceId": ""
      },
      "SourceCustomizedKafkaConnectorParameters": {
        "ConnectorPackageUrl": "",
        "ConnectorParameters": {
          "Name": "",
          "Config": {
            "test": "test",
            "test2": 1
          }
        },
        "WorkerParameters": {
          "test": "test",
          "test2": 1
        }
      },
      "SourceApacheKafkaParameters": {
        "Bootstraps": "",
        "Topic": "",
        "ConsumerGroup": "",
        "OffsetReset": "",
        "ValueDataType": "",
        "VpcId": "",
        "VSwitchIds": "",
        "SecurityGroupId": "",
        "NetworkType": "",
        "SecurityProtocol": "",
        "SaslMechanism": "",
        "SaslUser": "",
        "SaslPassword": ""
      }
    },
    "FilterPattern": "",
    "Transforms": [
      {
        "Arn": "acs:fc:cn-hangzhou:*****:services/demo-service.LATEST/functions/demo-func\n"
      }
    ],
    "Sink": {
      "SinkMNSParameters": {
        "QueueName": {
          "Value": "MyQueue",
          "Form": "CONSTANT",
          "Template": ""
        },
        "Body": {
          "Value": "{\n      \"key\": \"value\"\n}",
          "Form": "TEMPLATE",
          "Template": "The value of ${key} is ${value}!"
        },
        "IsBase64Encode": {
          "Value": "true",
          "Form": "CONSTANT",
          "Template": ""
        }
      },
      "SinkRabbitMQParameters": {
        "InstanceId": {
          "Value": "e5c9b727-e06c-4d7e-84d5-f8ce644e00bf",
          "Form": "CONSTANT",
          "Template": ""
        },
        "VirtualHostName": {
          "Value": "rabbit-host\n",
          "Form": "CONSTANT",
          "Template": ""
        },
        "TargetType": {
          "Value": "Exchange/Queue",
          "Form": "CONSTANT",
          "Template": ""
        },
        "Exchange": {
          "Value": "a_exchange",
          "Form": "CONSTANT",
          "Template": ""
        },
        "RoutingKey": {
          "Value": "housekeeping",
          "Form": "CONSTANT",
          "Template": ""
        },
        "QueueName": {
          "Value": "MyQueue",
          "Form": "CONSTANT",
          "Template": ""
        },
        "Body": {
          "Value": "{\n      \"key\": \"value\"\n}",
          "Form": "TEMPLATE",
          "Template": "The value of ${key} is ${value}!"
        },
        "MessageId": {
          "Value": "{\n      \"key\": \"value\"\n}",
          "Form": "TEMPLATE",
          "Template": "The value of ${key} is ${value}!"
        },
        "Properties": {
          "Value": "{\n      \"key\": \"value\"\n}",
          "Form": "TEMPLATE",
          "Template": "The value of ${key} is ${value}!\n"
        }
      },
      "SinkFcParameters": {
        "ServiceName": {
          "Value": "myService",
          "Form": "CONSTANT",
          "Template": ""
        },
        "FunctionName": {
          "Value": "mFunction",
          "Form": "CONSTANT",
          "Template": ""
        },
        "Concurrency": {
          "Value": "1",
          "Form": "CONSTANT",
          "Template": "None\n"
        },
        "Qualifier": {
          "Value": "LATEST",
          "Form": "CONSTANT",
          "Template": ""
        },
        "InvocationType": {
          "Value": "Async",
          "Form": "CONSTANT",
          "Template": ""
        },
        "Body": {
          "Value": "{\n      \"key\": \"value\"\n}",
          "Form": "TEMPLATE",
          "Template": "The value of ${key} is ${value}!\n"
        }
      },
      "SinkKafkaParameters": {
        "InstanceId": {
          "Value": "Defaut_1283278472_sadkj",
          "Form": "CONSTANT",
          "Template": ""
        },
        "Topic": {
          "Value": "topic-test",
          "Form": "CONSTANT",
          "Template": ""
        },
        "Acks": {
          "Value": "1",
          "Form": "CONSTANT",
          "Template": ""
        },
        "Key": {
          "Value": "key",
          "Form": "CONSTANT",
          "Template": ""
        },
        "Value": {
          "Value": "{\n      \"key\": \"value\"\n}",
          "Form": "TEMPLATE",
          "Template": "The value of ${key} is ${value}!\n"
        }
      },
      "SinkRocketMQParameters": {
        "InstanceId": {
          "Value": "MQ_INST_164901546557****_BAAN****",
          "Form": "CONSTANT",
          "Template": ""
        },
        "Topic": {
          "Value": "Mytopic",
          "Form": "CONSTANT",
          "Template": ""
        },
        "Body": {
          "Value": "{\n      \"key\": \"value\"\n}",
          "Form": "TEMPLATE",
          "Template": "The value of ${key} is ${value}!\n"
        },
        "Properties": {
          "Value": "{\n      \"key\": \"value\"\n}",
          "Form": "TEMPLATE",
          "Template": "The value of ${key} is ${value}!\n"
        },
        "Keys": {
          "Value": "{\n      \"key\": \"value\"\n}",
          "Form": "TEMPLATE",
          "Template": "The value of ${key} is ${value}!"
        },
        "Tags": {
          "Value": "{\n      \"key\": \"value\"\n}",
          "Form": "TEMPLATE",
          "Template": "The value of ${key} is ${value}!"
        },
        "InstanceType": {
          "Value": "",
          "Form": "",
          "Template": ""
        },
        "InstanceEndpoint": {
          "Value": "",
          "Form": "",
          "Template": ""
        },
        "InstanceUsername": {
          "Value": "",
          "Form": "",
          "Template": ""
        },
        "InstancePassword": {
          "Value": "",
          "Form": "",
          "Template": ""
        },
        "VpcId": {
          "Value": "",
          "Form": "",
          "Template": ""
        },
        "VSwitchIds": {
          "Value": "",
          "Form": "",
          "Template": ""
        },
        "SecurityGroupId": {
          "Value": "",
          "Form": "",
          "Template": ""
        },
        "Network": {
          "Value": "",
          "Form": "",
          "Template": ""
        }
      },
      "SinkSLSParameters": {
        "Project": {
          "Value": "test-project\n",
          "Form": "CONSTANT",
          "Template": ""
        },
        "LogStore": {
          "Value": "test-logstore",
          "Form": "CONSTANT",
          "Template": ""
        },
        "Topic": {
          "Value": "testTopic",
          "Form": "CONSTANT",
          "Template": ""
        },
        "Body": {
          "Value": "{\n      \"key\": \"value\"\n}",
          "Form": "TEMPLATE",
          "Template": "The value of ${key} is ${value}!\n"
        },
        "RoleName": {
          "Value": "testRole",
          "Form": "CONSTANT",
          "Template": ""
        },
        "ContentType": {
          "Value": "",
          "Form": "",
          "Template": ""
        },
        "ContentSchema": {
          "Value": "",
          "Form": "",
          "Template": ""
        }
      },
      "SinkFnfParameters": {
        "FlowName": {
          "Value": "test-streaming-fnf",
          "Form": "CONSTANT",
          "Template": "None\n"
        },
        "ExecutionName": {
          "Value": "123",
          "Form": "CONSTANT",
          "Template": "None\n"
        },
        "Input": {
          "Value": "123",
          "Form": "CONSTANT",
          "Template": "None\n"
        },
        "RoleName": {
          "Value": "Al****FNF-x****",
          "Form": "CONSTANT",
          "Template": "None\n"
        }
      },
      "SinkDataHubParameters": {
        "Project": {
          "Value": "",
          "Form": "",
          "Template": ""
        },
        "Topic": {
          "Value": "",
          "Form": "",
          "Template": ""
        },
        "TopicType": {
          "Value": "",
          "Form": "",
          "Template": ""
        },
        "TopicSchema": {
          "Value": "",
          "Form": "",
          "Template": ""
        },
        "Body": {
          "Value": "",
          "Form": "",
          "Template": ""
        },
        "RoleName": {
          "Value": "",
          "Form": "",
          "Template": ""
        }
      },
      "SinkCustomizedKafkaParameters": {
        "InstanceId": ""
      },
      "SinkCustomizedKafkaConnectorParameters": {
        "ConnectorPackageUrl": "",
        "ConnectorParameters": {
          "Name": "",
          "Config": {
            "test": "test",
            "test2": 1
          }
        },
        "WorkerParameters": {
          "test": "test",
          "test2": 1
        }
      },
      "SinkDashVectorParameters": {
        "InstanceId": "",
        "Collection": "",
        "ApiKey": "",
        "Operation": "",
        "Network": "",
        "PrimaryKeyId": {
          "Form": "",
          "Value": "",
          "Template": ""
        },
        "Partition": {
          "Form": "",
          "Value": "",
          "Template": ""
        },
        "Vector": {
          "Form": "",
          "Value": "",
          "Template": ""
        },
        "DashVectorSchemaParameters": {
          "Form": "",
          "Value": "",
          "Template": ""
        }
      }
    },
    "RunOptions": {
      "MaximumTasks": 2,
      "RetryStrategy": {
        "PushRetryStrategy": "BACKOFFRETRY",
        "MaximumEventAgeInSeconds": 512,
        "MaximumRetryAttempts": 2
      },
      "ErrorsTolerance": "ALL",
      "DeadLetterQueue": {
        "Arn": "acs:ram::1550203943326350:role/edskmstoecs"
      },
      "BatchWindow": {
        "CountBasedWindow": 100,
        "TimeBasedWindow": 10
      },
      "LogDelivery": {
        "SLSLogParameters": [
          {
            "ProjectName": "",
            "LogstoreName": ""
          }
        ],
        "KafkaLogParameters": [
          {
            "Endpoint": "",
            "InstanceId": "",
            "Topic": ""
          }
        ]
      },
      "ScaledObject": {
        "MinReplicaCount": 0,
        "MaxReplicaCount": 0,
        "Triggers": [
          {
            "Type": "",
            "Metadata": {
              "Type": "",
              "Value": 0
            }
          }
        ]
      },
      "RoleName": "",
      "Network": {
        "VpcId": "",
        "VSwitchIds": [
          ""
        ],
        "SecurityGroupId": ""
      },
      "ResourceSpec": {
        "Resources": [
          {
            "Type": "",
            "Value": 0
          }
        ]
      }
    },
    "Status": "RUNNING",
    "DetailedStatus": {
      "TPS": 0,
      "DelayTime": 0,
      "DiffOffset": 0,
      "Extensions": {
        "test": "test",
        "test2": 1
      }
    }
  },
  "Code": "Success",
  "Success": true
}

Error codes

HTTP status codeError codeError message
403ServiceNotEnableService not enable

For a list of error codes, visit the Service error codes.

Change history

Change timeSummary of changesOperation
2024-09-10The Error code has changed. The response structure of the API has changedView Change Details
2024-08-19The Error code has changed. The response structure of the API has changedView Change Details
2024-07-12The Error code has changed. The response structure of the API has changedView Change Details
2024-05-31The Error code has changed. The response structure of the API has changedView Change Details
2024-04-09The Error code has changed. The response structure of the API has changedView Change Details
2024-02-21The Error code has changed. The response structure of the API has changedView Change Details
2023-12-28The Error code has changed. The response structure of the API has changedView Change Details
2023-11-22The Error code has changed. The response structure of the API has changedView Change Details
2023-10-11The Error code has changed. The response structure of the API has changedView Change Details
2023-09-13The Error code has changed. The response structure of the API has changedView Change Details
2023-04-21The Error code has changed. The response structure of the API has changedView Change Details
2023-04-06The Error code has changedView Change Details