查询事件流。
接口说明
查询事件流。
调试
您可以在OpenAPI Explorer中直接运行该接口，免去您计算签名的困扰。运行成功后，OpenAPI Explorer可以自动生成SDK代码示例。
授权信息
下表是API对应的授权信息，可以在RAM权限策略语句的Action元素中使用，用来给RAM用户或RAM角色授予调用此API的权限。具体说明如下：
- 操作：是指具体的权限点。
- 访问级别：是指每个操作的访问级别，取值为写入（Write）、读取（Read）或列出（List）。
- 资源类型：是指操作中支持授权的资源类型。具体说明如下：
- 对于必选的资源类型，用背景高亮的方式表示。
- 对于不支持资源级授权的操作，用
全部资源表示。
- 条件关键字：是指云产品自身定义的条件关键字。
- 关联操作：是指成功执行操作所需要的其他权限。操作者必须同时具备关联操作的权限，操作才能成功。
| 操作 | 访问级别 | 资源类型 | 条件关键字 | 关联操作 |
|---|---|---|---|---|
| eventbridge:ListEventStreamings | list |
|
| 无 |
请求参数
| 名称 | 类型 | 必填 | 描述 | 示例值 |
|---|---|---|---|---|
| NamePrefix | string | 否 | 名称。 | name |
| Limit | integer | 否 | 限定每次返回的最大条数，可以和 NextToken 搭配使用实现翻页能力。 注意 每次返回的最大条数不超过 100。 | 10 |
| NextToken | string | 否 | 当指定 Limit 时，如果还有多余的返回值则会返回 NextToken。 | 10 |
| SourceArn | string | 否 | 事件源 Arn。 | acs:alikafka:cn-hangzhou:118609547428****:instance/alikafka_pre-cn-zxu36kvi****/topic/test-topic |
| SinkArn | string | 否 | 事件目标 Arn。 | acs:fc:cn-hangzhou:118609547428****:services/fw1.LATEST/functions/log1 |
返回参数
示例
正常返回示例
JSON格式
{
"Message": "The event streaming [xxxx] not existed!\n",
"RequestId": "283FF852-C4B8-58C9-9777-F88A5A16****",
"Data": {
"EventStreamings": [
{
"EventStreamingName": "name",
"Description": "demo",
"Source": {
"SourceMNSParameters": {
"RegionId": "cn-zhangjiakou",
"QueueName": "work4",
"IsBase64Decode": true
},
"SourceRabbitMQParameters": {
"RegionId": "cn-zhangjiakou",
"InstanceId": "dbaudit-cn-7mz2hqo****",
"VirtualHostName": "eb-connect\n",
"QueueName": "liuyang"
},
"SourceRocketMQParameters": {
"RegionId": "cn-chengdu",
"InstanceId": "i-f8zbher64dlm58pl****\n",
"Topic": "topic_add_anima",
"Tag": "v1",
"Offset": "CONSUMEFROMTIMESTAMP",
"GroupID": "GID_group1",
"Timestamp": 1670742074043,
"InstanceType": "Cloud_4\n",
"InstanceEndpoint": "registry-vpc.cn-hangzhou.aliyuncs.com",
"AuthType": "ACL",
"InstanceUsername": "admin**",
"InstancePassword": "123",
"InstanceVpcId": "vpc-bp1a4gmlk31hy***l3ss",
"InstanceVSwitchIds": "vsw-m5ev8asdc6h123456****\n",
"InstanceSecurityGroupId": "sg-m5edtu24f12345****\n",
"InstanceNetwork": "PublicNetwork",
"BodyDataType": "JSON\n",
"Network": "PublicNetwork",
"FilterType": "Tag\n",
"FilterSql": "index > 10\n",
"VpcId": "vpc-m5e3sv4b12345****\n",
"VSwitchIds": "vsw-m5ev8asdc6h12345****\n",
"SecurityGroupId": "sg-m5edtu24f12345****\n"
},
"SourceKafkaParameters": {
"RegionId": "cn-chengdu",
"InstanceId": "bastionhost-cn-i7m2gwt****",
"Topic": "topic_empower_1642473600414\n",
"ConsumerGroup": "GID_TEST",
"OffsetReset": "latest",
"Network": "Default",
"VpcId": "vpc-wz9ki1qdlx3cx5cbf****",
"VSwitchIds": "vsw-bp1rmi8rind7eo50c****",
"SecurityGroupId": "sg-5ud5f3p0rqqis69****eho7cp",
"ValueDataType": "JSON\n"
},
"SourceMQTTParameters": {
"RegionId": "cn-qingdao",
"InstanceId": "bastionhost-cn-zvp27kc****",
"Topic": "migration_instance",
"BodyDataType": "JSON\n"
},
"SourceDTSParameters": {
"TaskId": "1611b337285f44e2936a2c4170****",
"BrokerUrl": "无",
"Topic": "TP_TEST_UNDERWRITE_ISSUE\n",
"Sid": "HG9",
"Username": "admin",
"Password": "123456",
"InitCheckPoint": "1620962769"
},
"SourceSLSParameters": {
"Project": "dmmzk",
"LogStore": "waf-logstore\n",
"ConsumerGroup": "go-dts-shelf-group",
"ConsumePosition": "begin",
"RoleName": "testRole"
},
"SourcePrometheusParameters": {
"RegionId": "cn-beijing",
"ClusterId": "c83555068b6******ad213f565f209\n",
"DataType": "JSON\n",
"Labels": "__name__=.*\n"
},
"SourceCustomizedKafkaParameters": {
"InstanceId": "gtm-cn-k2c2yfg****\n"
},
"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": {
"Name": "test-name\n",
"Config": {
"connector.class": "com.mongodb.kafka.connect.MongoSinkConnector",
"tasks.max": "1",
"topics": "sourceA,sourceB"
}
},
"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"
}
},
"SourceOSSParameters": {
"RoleName": "eventbridge_oss_role\n",
"BucketName": "bucket_abc\n",
"Prefix": "fun/document/\n",
"LoadMode": "single\n",
"LoadFormat": "TextLoader\n",
"Delimiter": "\\n\n"
}
},
"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}!\n"
},
"IsBase64Encode": {
"Value": "true",
"Form": "CONSTANT",
"Template": "无"
}
},
"SinkFcParameters": {
"ServiceName": {
"Value": "myService",
"Form": "CONSTANT",
"Template": "无"
},
"FunctionName": {
"Value": "mFunction",
"Form": "CONSTANT",
"Template": "无"
},
"Concurrency": {
"Value": "1",
"Form": "CONSTANT",
"Template": "无"
},
"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"
}
},
"SinkRabbitMQParameters": {
"InstanceId": {
"Value": "si-296cd57939a1421b****",
"Form": "CONSTANT",
"Template": "无"
},
"VirtualHostName": {
"Value": "rabbit-host\n",
"Form": "CONSTANT",
"Template": "无"
},
"TargetType": {
"Value": "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}!\n"
},
"MessageId": {
"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"
}
},
"SinkKafkaParameters": {
"InstanceId": {
"Value": "Defaut_1283278472_sad****",
"Form": "CONSTANT",
"Template": "无"
},
"Topic": {
"Value": "topic",
"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****\n",
"Form": "CONSTANT",
"Template": "无"
},
"Topic": {
"Value": "topic",
"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}!\n"
},
"Tags": {
"Value": "{\n \"key\": \"value\"\n}",
"Form": "TEMPLATE",
"Template": "The value of ${key} is ${value}!\n"
},
"InstanceType": {
"Value": "Cloud_4",
"Form": "CONSTANT\n",
"Template": "无"
},
"InstanceEndpoint": {
"Value": "vbr-8vbsvkkbpf3vb0zef****\n",
"Form": "CONSTANT\n",
"Template": "无"
},
"InstanceUsername": {
"Value": "admin\n",
"Form": "CONSTANT\n",
"Template": "无"
},
"InstancePassword": {
"Value": "admin******\n",
"Form": "CONSTANT\n",
"Template": "无"
},
"VpcId": {
"Value": "vbr-8vb835n3zf9shwlvb****\n",
"Form": "CONSTANT\n",
"Template": "无"
},
"VSwitchIds": {
"Value": "vbr-8vb835n3zf9shwl****mp\n",
"Form": "CONSTANT\n\n",
"Template": "无"
},
"SecurityGroupId": {
"Value": "b4bf375515f6440f942e3a20c33d****\n",
"Form": "CONSTANT\n",
"Template": "无\n"
},
"Network": {
"Value": "PublicNetwork\n",
"Form": "CONSTANT\n",
"Template": "无"
}
},
"SinkSLSParameters": {
"Project": {
"Value": "test-project\n",
"Form": "CONSTANT",
"Template": "无"
},
"LogStore": {
"Value": "test-logstore\n",
"Form": "CONSTANT",
"Template": "无"
},
"Topic": {
"Value": "topic",
"Form": "CONSTANT",
"Template": "无"
},
"Body": {
"Value": "{\n \"key\": \"value\"\n}",
"Form": "TEMPLATE",
"Template": "The value of ${key} is ${value}!\n"
},
"RoleName": {
"Value": "test-role",
"Form": "CONSTANT",
"Template": "无"
},
"ContentType": {
"Value": "JSON\n",
"Form": "CONSTANT",
"Template": "无"
},
"ContentSchema": {
"Value": "{\"Key_1\":{\"form\":\"CONSTANT\",\"value\":\"demoKey\"},\"Value_1\":{\"form\":\"JSONPATH\",\"value\":\"$.data.value\"}}",
"Form": "CONSTANT\n",
"Template": "无"
}
},
"SinkFnfParameters": {
"FlowName": {
"Value": "test-streaming-fnf\n",
"Form": "CONSTANT",
"Template": "无"
},
"ExecutionName": {
"Value": "123",
"Form": "CONSTANT",
"Template": "无"
},
"Input": {
"Value": "123",
"Form": "CONSTANT",
"Template": "无"
},
"RoleName": {
"Value": "Al****FNF-x****\n",
"Form": "CONSTANT",
"Template": "无"
}
},
"SinkDataHubParameters": {
"Project": {
"Value": "demo-project\n",
"Form": "CONSTANT\n",
"Template": "无"
},
"Topic": {
"Value": "demo-topic\n",
"Form": "CONSTANT\n",
"Template": "无"
},
"TopicType": {
"Value": "TUPLE\n",
"Form": "CONSTANT\n",
"Template": "无"
},
"TopicSchema": {
"Value": "{\"k1\":\"value1\",\"k2\":\"value2\"}\n",
"Form": "CONSTANT",
"Template": "无"
},
"Body": {
"Value": "无",
"Form": "ORIGINAL\n",
"Template": "无"
},
"RoleName": {
"Value": "testRole\n",
"Form": "CONSTANT\n",
"Template": "无"
}
},
"SinkCustomizedKafkaParameters": {
"InstanceId": "90be1f96-4229-4535-bb76-34b4f6fb2b71\n"
},
"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": {
"Name": "mongo-sink\n",
"Config": {
"connector.class": "com.mongodb.kafka.connect.MongoSinkConnector",
"tasks.max": "1",
"topics": "sourceA,sourceB"
}
},
"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"
}
},
"SinkDashVectorParameters": {
"InstanceId": "vrs-cn-lbj3ru1***\n",
"Collection": "collection1\n",
"ApiKey": "Q34nExQH7sQ****\n",
"Operation": "Upsert\n",
"Network": "PublicNetwork\n",
"PrimaryKeyId": {
"Form": "JSONPATH\n",
"Value": "$.data.requestId\n",
"Template": "${ID}\n"
},
"Partition": {
"Form": "CONSTANT\n",
"Value": "default\n",
"Template": "无"
},
"Vector": {
"Form": "JSONPATH\n",
"Value": "$.data.messageBody\n",
"Template": "无"
},
"DashVectorSchemaParameters": {
"Form": "TEMPLATE\n",
"Value": "{\n \"value1\":\"v1\",\n \"value2\":\"v2\"\n}",
"Template": "[\n {\n \"name\": \"schema1\",\n \"type\": \"INT\",\n \"value\": \"${value1}\"\n },\n {\n \"name\": \"schema2\",\n \"type\": \"FLOAT\",\n \"value\": \"${value2}\"\n }\n]"
}
}
},
"RunOptions": {
"MaximumTasks": 2,
"RetryStrategy": {
"PushRetryStrategy": "EXPONENTIAL_DECAY_RETRY",
"MaximumEventAgeInSeconds": 512,
"MaximumRetryAttempts": 2
},
"ErrorsTolerance": "ALL",
"DeadLetterQueue": {
"Arn": "acs:ram::159787121179****:role/aliyunsaedefaultrole"
},
"BatchWindow": {
"CountBasedWindow": 100,
"TimeBasedWindow": 10
}
},
"Status": "RUNNING"
}
],
"NextToken": "177",
"Total": 10
},
"Code": "Success",
"Success": true
}错误码
| HTTP status code | 错误码 | 错误信息 |
|---|---|---|
| 403 | ServiceNotEnable | Service not enable |
访问错误中心查看更多错误码。
变更历史
| 变更时间 | 变更内容概要 | 操作 |
|---|---|---|
| 2024-09-10 | OpenAPI 错误码发生变更、OpenAPI 返回结构发生变更 | 查看变更详情 |
| 2024-08-19 | OpenAPI 错误码发生变更、OpenAPI 返回结构发生变更 | 查看变更详情 |
| 2024-07-12 | OpenAPI 错误码发生变更、OpenAPI 返回结构发生变更 | 查看变更详情 |
| 2024-06-28 | OpenAPI 错误码发生变更、OpenAPI 返回结构发生变更 | 查看变更详情 |
| 2024-05-31 | OpenAPI 错误码发生变更、OpenAPI 返回结构发生变更 | 查看变更详情 |
| 2024-04-09 | OpenAPI 错误码发生变更、OpenAPI 返回结构发生变更 | 查看变更详情 |
| 2023-11-22 | OpenAPI 错误码发生变更、OpenAPI 返回结构发生变更 | 查看变更详情 |
| 2023-10-11 | OpenAPI 错误码发生变更、OpenAPI 返回结构发生变更 | 查看变更详情 |
| 2023-09-13 | OpenAPI 错误码发生变更、OpenAPI 返回结构发生变更 | 查看变更详情 |
| 2023-06-09 | OpenAPI 错误码发生变更、OpenAPI 入参发生变更 | 查看变更详情 |
| 2023-04-21 | OpenAPI 错误码发生变更、OpenAPI 返回结构发生变更 | 查看变更详情 |
| 2023-04-10 | OpenAPI 错误码发生变更 | 查看变更详情 |