全部產品
Search
文件中心

EventBridge:ListEventStreamings

更新時間:Jun 17, 2026

查詢事件流。

介面說明

查詢事件流。

調試

您可以在OpenAPI Explorer中直接運行該介面,免去您計算簽名的困擾。運行成功後,OpenAPI Explorer可以自動產生SDK程式碼範例。

調試

授權資訊

下表是API對應的授權資訊,可以在RAM權限原則語句的Action元素中使用,用來給RAM使用者或RAM角色授予調用此API的許可權。具體說明如下:

  • 操作:是指具體的許可權點。

  • 存取層級:是指每個操作的存取層級,取值為寫入(Write)、讀取(Read)或列出(List)。

  • 資源類型:是指操作中支援授權的資源類型。具體說明如下:

    • 對於必選的資源類型,用前面加 * 表示。

    • 對於不支援資源級授權的操作,用全部資源表示。

  • 條件關鍵字:是指雲產品自身定義的條件關鍵字。

  • 關聯操作:是指成功執行操作所需要的其他許可權。操作者必須同時具備關聯操作的許可權,操作才能成功。

操作

存取層級

資源類型

條件關鍵字

關聯操作

eventbridge:ListEventStreamings

list

*EventStreaming

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

請求參數

名稱

類型

必填

描述

樣本值

NamePrefix

string

事件流名稱前綴。

name

Limit

integer

限定每次返回的最大條數,可以和 NextToken 搭配使用實現翻頁能力。

重要 每次返回的最大條數不超過 100。

10

NextToken

string

當指定 Limit 時,如果還有多餘的返回值則會返回 NextToken。

10

Tags

array<object>

標籤篩選。

object

標籤。

Key

string

標籤鍵。

mns

Value

string

標籤值。

mnstest

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

返回參數

名稱

類型

描述

樣本值

object

返回資訊。

Message

string

錯誤資訊。

The event streaming [xxxx] not existed!

RequestId

string

阿里雲為該請求生成的唯一識別碼。

283FF852-C4B8-58C9-9777-F88A5A16****

Data

object

事件流列表。

EventStreamings

array<object>

事件流列表。

array<object>

事件流實體。

EventStreamingName

string

事件流名稱。

name

Description

string

事件流描述資訊。

demo

Source

object

事件提供方。

SourceMNSParameters

object

Source 輕量訊息佇列(原 MNS) 源。

RegionId

string

地區 ID。

cn-zhangjiakou

QueueName

string

輕量訊息佇列(原 MNS)的 Queue 的名稱。

work4

IsBase64Decode

boolean

是否開啟 Base 64 編碼。

true

SourceRabbitMQParameters

object

Source RabbitMQ 源。

RegionId

string

地區 ID。

cn-zhangjiakou

InstanceId

string

訊息佇列 RabbitMQ 版的執行個體的 ID。

dbaudit-cn-7mz2hqo****

VirtualHostName

string

訊息佇列 RabbitMQ 版執行個體的 Vhost 的名稱。

eb-connect

QueueName

string

訊息佇列 RabbitMQ 版執行個體的 Queue 的名稱。

liuyang

SourceRocketMQParameters

object

Source RocketMQ 源。

RegionId

string

訊息佇列 RocketMQ 版的地區 ID。

cn-chengdu

InstanceId

string

訊息佇列 RocketMQ 版的執行個體 id。

i-f8zbher64dlm58pl****

Topic

string

訊息的 Topic。

topic_add_anima

Tag

string

訊息的過濾標籤。

v1

Offset

string

訊息的消費位點。取值說明如下: CONSUMEFROMLASTOFFSET:從最新位點開始消費。 CONSUMEFROMFIRSTOFFSET:從最早位點開始消費。 CONSUMEFROMTIMESTAMP:從指定時間點的位點開始消費。

CONSUMEFROMTIMESTAMP

GroupID

string

訊息佇列 RocketMQ 版的 Group ID。

GID_group1

Timestamp

integer

時間戳記。僅當參數 Offset 取值為 CONSUMEFROMTIMESTAMP 時,該參數有效。

1670742074043

InstanceType

string

執行個體類型。取值說明如下:

  • Cloud_4:阿里雲 RocketMQ 4.0 版本執行個體(預設選項)

  • Cloud_5:阿里雲 RocketMQ 5.0 版本執行個體

  • SelfBuilt:自建 Apache RocketMQ 叢集

Cloud_4

InstanceEndpoint

string

執行個體存取點。

registry-vpc.cn-hangzhou.aliyuncs.com

AuthType

string

鑒權類型。

ACL

InstanceUsername

string

執行個體使用者名稱。

admin**

InstancePassword

string

執行個體密碼。

123

InstanceVpcId

string

Virtual Private Cloud 的 ID。

vpc-bp1a4gmlk31hy***l3ss

InstanceVSwitchIds

string

執行個體交換器資訊。

vsw-m5ev8asdc6h123456****

InstanceSecurityGroupId

string

執行個體安全性群組資訊。

sg-m5edtu24f12345****

InstanceNetwork

string

執行個體網路資訊:

  • PublicNetwork

  • PrivateNetwork

PublicNetwork

BodyDataType

string

訊息編碼格式:

  • JSON

  • Text

  • Binary

JSON

Network

string

網路類型。

  • PublicNetwork

  • PrivateNetwork

PublicNetwork

FilterType

string

訊息過濾類型。

Tag

FilterSql

string

sql 過濾語句。

index > 10

VpcId

string

VPC 的 ID。

vpc-m5e3sv4b12345****

VSwitchIds

string

虛擬交換器 ID。

vsw-m5ev8asdc6h12345****

SecurityGroupId

string

安全性群組 ID。

sg-m5edtu24f12345****

SourceRocketMQCheckpointParameters

object

Source RocketMQ Checkpoint 源

RegionId

string

地區 ID。

cn-hangzhou

InstanceType

string

訊息佇列 RocketMQ 版執行個體的類型。

Cloud_5

InstanceId

string

訊息佇列 RocketMQ 版執行個體 ID。

rmq-cn-jte3w******

Topics

array

訊息佇列 RocketMQ 版執行個體 Topic。

string

訊息佇列 RocketMQ 版執行個體 Topic。

myTopic

SourceApacheRocketMQCheckpointParameters

object

Source RocketMQ Checkpoint 源

RegionId

string

地區 ID。

cn-hangzhou

Topics

array

Apache RocketMQ 執行個體 Topic。

string

Apache RocketMQ 執行個體 Topic。

myTopic

InstanceEndpoint

string

Apache RocketMQ 執行個體的存取點。

192.168.1.1:9876

InstanceUsername

string

Apache RocketMQ 執行個體的使用者名稱。

admin

InstancePassword

string

Apache RocketMQ 執行個體的密碼。

****

NetworkType

string

網路類型。

PrivateNetwork

VpcId

string

VPC ID。

vpc-adw1awdw*****

VSwitchId

string

交換器 ID。

vsw-dwaafds****

SecurityGroupId

string

安全性群組 ID。

sg-mw43*****

SourceKafkaParameters

object

Source Kafka 源。

RegionId

string

執行個體所在地區 id。

cn-chengdu

InstanceId

string

執行個體 id。

bastionhost-cn-i7m2gwt****

Topic

string

Topic 名稱。

topic_empower_1642473600414

ConsumerGroup

string

訂閱該 Topic 的消費者所對應的 Group ID。

GID_TEST

OffsetReset

string

位移量。

latest

Network

string

網路設定 :預設值 Default,vpc 網路是 PublicNetwork。

Default

VpcId

string

使用者的 VPC ID。

vpc-wz9ki1qdlx3cx5cbf****

VSwitchIds

string

交換器 ID。

vsw-bp1rmi8rind7eo50c****

SecurityGroupId

string

安全性群組 ID。

sg-5ud5f3p0rqqis69****eho7cp

ValueDataType

string

訊息體編解碼格式:

  • JSON

  • Text

  • Binary

JSON

SourceMQTTParameters

object

Source MQTT 源。

RegionId

string

地區 ID。

cn-qingdao

InstanceId

string

執行個體 id。

bastionhost-cn-zvp27kc****

Topic

string

Topic 名稱。

migration_instance

BodyDataType

string

訊息編碼格式:

  • JSON

  • Text

  • Binary

JSON

NetworkType

string

網路類型。

VpcId

string

VPC ID。

VSwitchIds

string

虛擬交換器 ID。

SecurityGroupId

string

安全性群組 ID。

SourceDTSParameters

object

Source DTS 源。

TaskId

string

任務 ID。

1611b337285f44e2936a2c4170****

BrokerUrl

string

資料訂閱通道的網路地址及連接埠號碼資訊。

Topic

string

資料訂閱通道的訂閱 Topic。

TP_TEST_UNDERWRITE_ISSUE

Sid

string

消費組 ID。

HG9

Username

string

消費組的帳號。

admin

Password

string

消費組的帳號密碼。

123456

InitCheckPoint

string

消費位點,即 SDK 用戶端消費第一條資料的時間戳記,格式為 Unix 時間戳記。

1620962769

SourceSLSParameters

object

Source SLS 源。

Project

string

Log Service SLS 的記錄項目。

dmmzk

LogStore

string

Log Service SLS 的日誌庫。

waf-logstore

ConsumerGroup

string

訂閱該 Topic 的消費者所對應的 Group ID。

go-dts-shelf-group

ConsumePosition

string

起始消費位點,可以選擇最早或最新位點,分別對應“begin”,“end”,也可以從指定時間開始消費,以秒為單位。

begin

RoleName

string

授權事件匯流排 EventBridge 使用此角色讀取 SLS 日誌內容時,需滿足條件:在 RAM 控制台建立服務所使用的角色時,需要選擇“阿里雲服務”,並且“受信服務”需要選擇“事件匯流排”。

testRole

SourcePrometheusParameters

object

Source Prometheus 事件來源。

RegionId

string

地區 ID。

cn-beijing

ClusterId

string

叢集 ID。

c83555068b6******ad213f565f209

DataType

string

資料類型。

JSON

Labels

string

標籤。

__name__=.*

RoleName

string

訪問 Prometheus 資料的角色。

testRole

ExternalLabels

string

事件中附加的自訂標籤。

{"source":"prometheus-prod"}

SourceCustomizedKafkaParameters

object

自訂 Kafka 事件來源。

InstanceId

string

執行個體 ID。

gtm-cn-k2c2yfg****

SourceCustomizedKafkaConnectorParameters

object

自訂連接器 Apache Kafka 事件來源。

ConnectorPackageUrl

string

OSS 資源 ZIP 包下載連結。

"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

連接器參數。

Name

string

連接器名稱。

test-name

Config

object

連接器配置。

{ "connector.class": "com.mongodb.kafka.connect.MongoSinkConnector", "tasks.max": "1", "topics": "sourceA,sourceB" }

WorkerParameters

object

kafka 執行個體配置。

{ "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

object

Source OSS 事件來源。

RoleName

string

授權事件匯流排 EventBridge 讀取 OSS 檔案的角色名稱,要求該角色至少具有 OSS 的唯讀許可權。

eventbridge_oss_role

BucketName

string

Object Storage Service 中的儲存空間名稱。

bucket_abc

Prefix

string

檔案路徑首碼。

fun/document/

LoadMode

string

資料載入模式,single 表示單文檔載入,element 表示分塊載入。 取值:single/element 預設為 single。

single

LoadFormat

string

文檔載入器。

TextLoader

Delimiter

string

分隔字元,在分塊載入模式下,以該分隔字元作為文本的分塊標識符,預設以分行符號\n 作為分隔字元。

\n

SourceOpenSourceRabbitMQParameters

object

Source Open Source RabbitMQ 源。

Endpoint

string

執行個體存取點。

192.168.1.1:9876

VirtualHostName

string

開源 RabbitMQ 執行個體的虛擬機器主機名稱。

Vhost1

QueueName

string

開源 RabbitMQ 執行個體的隊列名稱。

demo

BodyDataType

string

訊息體資料類型。

Json

Username

string

串連開源 RabbitMQ 執行個體時使用的使用者名稱。

admin

Password

string

串連開源 RabbitMQ 執行個體時使用的密碼。

****

VpcId

string

VPC ID。

vpc-m5e3sv4b12345****

VSwitchIds

string

交換器 ID。

vsw-m5ev8asdc6h12345****

SecurityGroupId

string

安全性群組 ID。

sg-m5edtu24f12345****

NetworkType

string

網路類型。

PrivateNetwork

AuthType

string

鑒權類型。

ACL

SourceEventBusParameters

object

Source EventBus 源。

EventBusName

string

事件匯流排名稱。

my-event-bus

EventRuleName

string

事件規則名稱。

my-event-rule

SourceMySQLParameters SourceMySQLParameters

Source MySQL 源。

SourcePostgreSQLParameters SourcePostgreSQLParameters

SourceRabbitMQMetaParameters SourceRabbitMQMetaParameters

SourceRabbitMQMsgSyncParameters SourceRabbitMQMsgSyncParameters

SourceFeiShuDocsParameters SourceFeiShuDocsParameters

FilterPattern

string

事件過濾規則,如果不指定表示匹配全部事件。

Transforms

array<object>

Transform 相關配置。

object

雲產品的 ARN,比如 Function Compute 中函數的 ARN。

Arn

string

雲產品的 ARN,比如 Function Compute 中函數的 ARN。

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

DashScopeTransformParameters

DashScopeTransformParameters

BaiLianAgentTransformParameters

BaiLianAgentTransformParameters

Sink

object

事件目標。

SinkMNSParameters

object

輕量訊息佇列(原 MNS)事件目標。

QueueName

object

目標服務類型為輕量訊息佇列(原 MNS)。

Value

string

輕量訊息佇列(原 MNS)的 Queue 的名稱。

MyQueue

Form

string

轉換的格式。預設為 CONSTANT。

CONSTANT

Template

string

Body

object

訊息內容。

Value

string

轉換前的值。

{ "key": "value" }

Form

string

轉換的格式。

TEMPLATE

Template

string

模板樣式。

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

IsBase64Encode

object

是否開啟 Base 64 編碼。

Value

string

開啟 Base 64 編碼。

true

Form

string

轉換的格式。預設為 CONSTANT。

CONSTANT

Template

string

SinkEventHouseParameters

object

事件目標名稱

CatalogName

string

catalog 名稱

cat1

NamespaceName

string

namespace 名稱

name1

EventTableName

string

表名稱

table1

MappingRules

array<object>

欄位對應規則

array<object>

映射規則

ColumnValue

object

列值擷取規則

Value

string

提取路徑

$.data.value

Form

string

提取方法

JSONPATH

Template

string

模板

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

ColumnName

string

列名稱

age

ColumnType

string

列類型

text

SinkFcParameters

object

函數目標。

ServiceName

object

服務的名稱。

Value

string

服務的名稱。

myService

Form

string

轉換的格式。預設為 CONSTANT。

CONSTANT

Template

string

FunctionName

object

函數名稱。

Value

string

函數名稱。

mFunction

Form

string

轉換的格式。預設為 CONSTANT。

CONSTANT

Template

string

Concurrency

object

投遞並發度,最小為 1。

Value

string

投遞並發度,最小為 1。

1

Form

string

轉換的格式。預設為 CONSTANT。

CONSTANT

Template

string

Qualifier

object

函數所屬服務的別名。

Value

string

函數所屬服務的別名。

LATEST

Form

string

轉換的格式。預設為 CONSTANT。

CONSTANT

Template

string

InvocationType

object

同步或則非同步。

  • Sync:同步。

  • Async:非同步。

Value

string

同步或則非同步。

  • Sync:同步。

  • Async:非同步。

Async

Form

string

轉換的格式。預設為 CONSTANT。

CONSTANT

Template

string

Body

object

發送給函數的內容體。

Value

string

轉換前的值。

{ "key": "value" }

Form

string

轉換的格式。

TEMPLATE

Template

string

模板樣式。

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

DataFormat

object

事件內容格式的轉換規則。

Value

string

轉換前的值。

{ "key": "value" }

Form

string

轉換格式,預設為 CONSTANT。

CONSTANT

Template

string

模板樣式。

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

SinkRabbitMQParameters

object

Sink Rabbitmq 的參數。

InstanceId

object

目標服務類型為訊息佇列 RabbitMQ 版。

Value

string

訊息佇列 RabbitMQ 版的執行個體 ID。

si-296cd57939a1421b****

Form

string

轉換的格式。預設為 CONSTANT。

CONSTANT

Template

string

VirtualHostName

object

訊息佇列 RabbitMQ 版執行個體的 Vhost 的名稱。

Value

string

訊息佇列 RabbitMQ 版執行個體的 Vhost 的名稱。

rabbit-host

Form

string

轉換的格式。預設為 CONSTANT。

CONSTANT

Template

string

TargetType

object

目標類型。

Value

string

目標類型。取值說明如下: Exchange:Exchange 模式。 Queue:Queue 模式。

Queue

Form

string

轉換的格式。預設為 CONSTANT。

CONSTANT

Template

string

Exchange

object

Exchange 模式。 僅當參數 TargetType 配置為 Exchange 時,需配置此參數。

Value

string

訊息佇列 RabbitMQ 版執行個體的 Exchange 的名稱。

a_exchange

Form

string

轉換的格式。預設為 CONSTANT。

CONSTANT

Template

string

RoutingKey

object

訊息的路由規則。 僅當參數 TargetType 配置為 Exchange 時,需配置此參數。

Value

string

訊息的路由規則。

housekeeping

Form

string

轉換的格式。預設為 CONSTANT。

CONSTANT

Template

string

QueueName

object

Queue 模式。 僅當參數 TargetType 配置為 Queue 時,需配置此參數。

Value

string

執行個體的 Queue 的名稱。

MyQueue

Form

string

轉換的格式。預設為 CONSTANT。

CONSTANT

Template

string

Body

object

訊息內容。

Value

string

轉換前的值。

{ "key": "value" }

Form

string

轉換的格式。

TEMPLATE

Template

string

模板樣式。

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

MessageId

object

訊息 ID。

Value

string

轉換前的值。

{ "key": "value" }

Form

string

轉換的格式。

TEMPLATE

Template

string

模板樣式。

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

Properties

object

過濾屬性。

Value

string

轉換前的值。

{ "key": "value" }

Form

string

轉換的格式。

TEMPLATE

Template

string

模板樣式。

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

SinkKafkaParameters

object

Sink kafka 參數。

InstanceId

object

目標服務類型為訊息佇列 Kafka 版。

Value

string

執行個體 ID。

Defaut_1283278472_sad****

Form

string

轉換的格式。預設為 CONSTANT。

CONSTANT

Template

string

CompressionType

string

Topic

object

主題名稱。

Value

string

主題名稱。

topic

Form

string

轉換的格式。預設為 CONSTANT。

CONSTANT

Template

string

DynamicTopic

object

指定訊息路由的目標 Topic 策略。若同時指定了 topic 參數和 topics 參數,以 topics 參數的值為準。支援以下兩種配置模式: 1. 靜態常量模式:直接填寫固定的 Topic 名稱字串(例如:"order_created")。所有訊息將統一發送至該 Topic。 2. 動態提模數式:填寫標準的 JSONPath 運算式(例如:"$.user.id" 或 "$.metadata.category")。系統將解析上遊訊息體,提取匹配欄位的值作為目標 Topic 名稱。

Value

string

Form

string

轉換的類型 CONSTANT:固定值 JSONPATH:根據路徑從上遊提取

Template

string

模板

Acks

object

寫入 Kafka 確認模式:

  • acks=0:無需服務端的 Response、效能較高、丟資料風險較大。

  • acks=1:服務端主節點寫成功即返回 Response、效能中等、丟資料風險中等、主節點宕機可能導致資料丟失;

  • acks=all:服務端主節點寫成功且備節點同步成功才返回 Response、效能較差、資料較為安全、主節點和備節點都宕機才會導致資料丟失。

Value

string

寫入 Kafka 確認模式:

  • acks=0:無需服務端的 Response、效能較高、丟資料風險較大。

  • acks=1:服務端主節點寫成功即返回 Response、效能中等、丟資料風險中等、主節點宕機可能導致資料丟失;

  • acks=all:服務端主節點寫成功且備節點同步成功才返回 Response、效能較差、資料較為安全、主節點和備節點都宕機才會導致資料丟失。

1

Form

string

轉換的格式。預設為 CONSTANT。

CONSTANT

Template

string

Key

object

訊息的標識。

Value

string

訊息的標識。

key

Form

string

轉換的格式。預設為 CONSTANT。

CONSTANT

Template

string

Value

object

訊息體內容。

Value

string

轉換前的值。

{ "key": "value" }

Form

string

轉換的格式。

TEMPLATE

Template

string

模板樣式。

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

SinkRocketMQParameters

object

Sink RocketMQ 源。

InstanceId

object

目標服務類型為訊息佇列 RocketMQ 版。

Value

string

訊息佇列 RocketMQ 版的執行個體 ID。

MQ_INST_164901546557****_BAAN****

Form

string

轉換的格式。預設為 CONSTANT。

CONSTANT

Template

string

Topic

object

訊息佇列 RocketMQ 版執行個體的 Topic。

Value

string

訊息佇列 RocketMQ 版執行個體的 Topic。

topic

Form

string

轉換的格式。預設為 CONSTANT。

CONSTANT

Template

string

Body

object

訊息內容。

Value

string

轉換前的值。

{ "key": "value" }

Form

string

轉換的格式。

TEMPLATE

Template

string

模板樣式。

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

Properties

object

過濾屬性。

Value

string

轉換前的值。

{ "key": "value" }

Form

string

轉換的格式。

TEMPLATE

Template

string

模板樣式。

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

Keys

object

過濾屬性。

Value

string

轉換前的值。

{ "key": "value" }

Form

string

轉換的格式。

TEMPLATE

Template

string

模板樣式。

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

Tags

object

過濾屬性。

Value

string

轉換前的值。

{ "key": "value" }

Form

string

轉換的格式。

TEMPLATE

Template

string

模板樣式。

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

InstanceType

object

執行個體類型。

Value

string

執行個體類型。取值說明如下:

  • Cloud_4:阿里雲 RocketMQ 4.0 版本執行個體(預設選項)

  • Cloud_5:阿里雲 RocketMQ 5.0 版本執行個體

  • SelfBuilt:自建 Apache RocketMQ 叢集

Cloud_4

Form

string

轉換的格式。預設為 CONSTANT。

CONSTANT

Template

string

InstanceEndpoint

object

執行個體存取點。

Value

string

執行個體存取點。

vbr-8vbsvkkbpf3vb0zef****

Form

string

轉換的格式。預設為 CONSTANT。

CONSTANT

Template

string

InstanceUsername

object

執行個體使用者名稱。

Value

string

執行個體使用者名稱。

admin

Form

string

轉換的格式。預設為 CONSTANT。

CONSTANT

Template

string

InstancePassword

object

執行個體密碼。

Value

string

執行個體密碼。

admin******

Form

string

轉換的格式。預設為 CONSTANT。

CONSTANT

Template

string

VpcId

object

VPC 的 ID。

Value

string

VPC 的 ID。

vbr-8vb835n3zf9shwlvb****

Form

string

事件轉換的格式。預設為 CONSTANT。

CONSTANT

Template

string

VSwitchIds

object

交換器 ID。

Value

string

交換器 ID。

vbr-8vb835n3zf9shwl****mp

Form

string

轉換的格式。預設為 CONSTANT。

CONSTANT

Template

string

SecurityGroupId

object

安全性群組 ID。

Value

string

安全性群組 ID。

b4bf375515f6440f942e3a20c33d****

Form

string

轉換的格式。預設為 CONSTANT。

CONSTANT

Template

string

Network

object

網路類型。

  • PublicNetwork

  • PrivateNetwork

Value

string

網路類型。

  • PublicNetwork

  • PrivateNetwork

PublicNetwork

Form

string

轉換的格式。預設為 CONSTANT。

CONSTANT

Template

string

DeliveryOrderType

object

訊息的投遞順序類型。

Value

string

投遞順序類型。

Orderly

Form

string

轉換格式,預設為 CONSTANT。

CONSTANT

Template

string

ShardingKey

object

訊息的分區鍵,用於控制訊息分區。

Value

string

分區索引值。

order_id

Form

string

轉換格式,預設為 CONSTANT。

CONSTANT

Template

string

模板樣式。

SinkDorisParameters

object

QueryEndpoint

object

Value

string

Form

string

Template

string

FeHttpEndpoint

object

Value

string

Form

string

Template

string

BeHttpEndpoint

object

Value

string

Form

string

Template

string

UserName

object

Value

string

Form

string

Template

string

Password

object

Value

string

Form

string

Template

string

Database

object

Value

string

Form

string

Template

string

Table

object

Value

string

Form

string

Template

string

Body

object

Value

string

Form

string

Template

string

NetworkType

object

Value

string

Form

string

Template

string

VpcId

object

Value

string

Form

string

Template

string

VSwitchIds

object

Value

string

Form

string

Template

string

SecurityGroupId

object

Value

string

Form

string

Template

string

SinkRocketMQCheckpointParameters

object

Sink RocketMQ Checkpoint 參數。

InstanceType

string

訊息佇列 RocketMQ 版的執行個體類型。

Cloud_5

InstanceId

string

RocketMQ 執行個體 ID。

MQ_INST_1825725063814405_BZ******

Topic

object

訊息佇列 RocketMQ 版執行個體的 Topic。

Value

string

Topic 的名稱。

myTopic

Form

string

轉換格式,預設為 CONSTANT。

CONSTANT

Template

string

模板樣式。

Group

object

訊息佇列 RocketMQ 版的消費者分組資訊。

Value

string

消費者分組的 Group ID。

GID_******

Form

string

轉換格式,預設為 CONSTANT。

CONSTANT

Template

string

模板樣式。

ConsumeTimestamp

object

消費位點。

Value

string

時間戳記。

1636597951964

Form

string

轉換格式,預設為 CONSTANT。

CONSTANT

Template

string

模板樣式。

SinkApacheRocketMQCheckpointParameters

object

Sink Apache RocketMQ Checkpoint 參數。

Topic

object

Apache RocketMQ 執行個體的 Topic 名稱。

Value

string

Topic 的名稱。

myTopic

Form

string

轉換格式,預設為 CONSTANT。

CONSTANT

Template

string

模板樣式。

Group

object

Apache RocketMQ 的消費者分組資訊。

Value

string

消費者分組的 Group ID。

GID_******

Form

string

轉換格式,預設為 CONSTANT。

CONSTANT

Template

string

模板樣式。

ConsumeTimestamp

object

消費位點。

Value

string

時間戳記。

1636597951964

Form

string

轉換格式,預設為 CONSTANT。

CONSTANT

Template

string

模板樣式。

InstanceEndpoint

string

Apache RocketMQ 執行個體的存取點。

192.168.1.1:9876

InstanceUsername

string

Apache RocketMQ 執行個體的使用者名稱。

admin

InstancePassword

string

Apache RocketMQ 執行個體的密碼。

****

NetworkType

string

網路類型。

PrivateNetwork

VpcId

string

VPC ID。

vpc-2zehizpoendb3****

VSwitchId

string

交換器 ID。

vsw-wz9qqeovkwjxlu9uc****

SecurityGroupId

string

安全性群組 ID。

sg-2vcgdxz7o1n9zapp****

SinkSLSParameters

object

Sink SLS Parameters

Project

object

Log Service SLS 的記錄項目。

Value

string

Log Service SLS 的記錄項目。

test-project

Form

string

轉換的格式。預設為 CONSTANT。

CONSTANT

Template

string

LogStore

object

Log Service SLS 的日誌庫。

Value

string

Log Service SLS 的日誌庫。

test-logstore

Form

string

轉換的格式。預設為 CONSTANT。

CONSTANT

Template

string

Topic

object

日誌所在的 topic,對應 SLS 保留欄位“topic”。

Value

string

日誌所在的 topic,對應 SLS 保留欄位“topic”。

topic

Form

string

轉換的格式。預設為 CONSTANT。

CONSTANT

Template

string

Body

object

發送給 SLS 的內容。

Value

string

轉換前的值。

{ "key": "value" }

Form

string

轉換的格式。

TEMPLATE

Template

string

模板樣式。

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

RoleName

object

授權事件匯流排 EventBridge 使用此角色讀取 SLS 日誌內容時,需滿足條件:在 RAM 控制台建立服務所使用的角色時,需要選擇“阿里雲服務”,並且“受信服務”需要選擇“事件匯流排”。

Value

string

授權事件匯流排 EventBridge 使用此角色讀取 SLS 日誌內容時,需滿足條件:在 RAM 控制台建立服務所使用的角色時,需要選擇“阿里雲服務”,並且“受信服務”需要選擇“事件匯流排”。

test-role

Form

string

轉換的格式。預設為 CONSTANT。

CONSTANT

Template

string

ContentType

object

SLS 資料格式。可選擇預設或者配置制定的索引值:

  • JSON

  • KeyValue

Value

string

SLS 資料格式。可選擇預設或者配置制定的索引值:

  • JSON

  • KeyValue

JSON

Form

string

轉換的格式。預設為 CONSTANT。

CONSTANT

Template

string

ContentSchema

object

自訂日誌的索引值,僅在 ContentType 為 KeyValue 生效。每一對索引值由 Key_n, Value_n 表示。

Value

string

轉換前的值。

{"Key_1":{"form":"CONSTANT","value":"demoKey"},"Value_1":{"form":"JSONPATH","value":"$.data.value"}}

Form

string

轉換的格式。預設為 CONSTANT。

CONSTANT

Template

string

SinkFnfParameters

object

Sink Fnf 參數。

FlowName

object

流程名稱。

Value

string

流程名稱。

test-streaming-fnf

Form

string

轉換的格式。預設為 CONSTANT。

CONSTANT

Template

string

模板樣式。

ExecutionName

object

執行名稱。

Value

string

執行名稱。

123

Form

string

轉換的格式。預設為 CONSTANT。

CONSTANT

Template

string

模板樣式。

Input

object

執行輸入資訊。

Value

string

執行輸入資訊。

123

Form

string

轉換的格式。預設為 CONSTANT。

CONSTANT

Template

string

模板樣式。

RoleName

object

角色配置。

Value

string

角色配置。

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

Form

string

轉換的格式。預設為 CONSTANT。

CONSTANT

Template

string

模板樣式。

SinkDataHubParameters

object

Sink DataHub 參數。

Project

object

DataHub 專案名。

Value

string

DataHub 專案名。

demo-project

Form

string

轉換的格式。預設為 CONSTANT。

CONSTANT

Template

string

Topic

object

DataHub Topic 名稱。

Value

string

DataHub Topic 名稱。

demo-topic

Form

string

轉換的格式。預設為 CONSTANT。

CONSTANT

Template

string

TopicType

object

topic 類型:

  • TUPLE

  • BLOB

Value

string

topic 類型:

  • TUPLE

  • BLOB

TUPLE

Form

string

轉換的格式。預設為 CONSTANT。

CONSTANT

Template

string

TopicSchema

object

TUBLE 類型,topic 內容模式。

Value

string

TUBLE 類型,topic 內容模式。

{"k1":"value1","k2":"value2"}

Form

string

轉換的格式。預設為 CONSTANT。

CONSTANT

Template

string

Body

object

BLOB 類型,Record 內容範本。

Value

string

BLOB 類型,Record 內容範本。

Form

string

轉換的格式。

ORIGINAL

Template

string

RoleName

object

授權事件匯流排 EventBridge 使用此角色讀取 SLS 日誌內容時,需滿足條件:在 RAM 控制台建立服務所使用的角色時,需要選擇“阿里雲服務”,並且“受信服務”需要選擇“事件匯流排”。

Value

string

授權事件匯流排 EventBridge 使用此角色讀取 SLS 日誌內容時,需滿足條件:在 RAM 控制台建立服務所使用的角色時,需要選擇“阿里雲服務”,並且“受信服務”需要選擇“事件匯流排”。

testRole

Form

string

轉換的格式。預設為 CONSTANT。

CONSTANT

Template

string

SinkCustomizedKafkaParameters

object

Sink Kafka 參數。

InstanceId

string

訊息佇列 Kafka 版的執行個體 ID。

90be1f96-4229-4535-bb76-34b4f6fb2b71

SinkCustomizedKafkaConnectorParameters

object

Sink Kafka 連接器參數。

ConnectorPackageUrl

string

OSS 檔案下載連結。

"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

解析當前 ZIP 包下的 properties 檔案。

Name

string

連接器名稱。

mongo-sink

Config

object

連接器配置。

{ "connector.class": "com.mongodb.kafka.connect.MongoSinkConnector", "tasks.max": "1", "topics": "sourceA,sourceB" }

WorkerParameters

object

執行個體配置。

{ "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

object

Sink DashVector 參數。

InstanceId

string

執行個體 ID。

vrs-cn-lbj3ru1***

Collection

string

Collection(集合)名稱。

collection1

ApiKey

string

DashVecotor 控制台建立的 API Key。

Q34nExQH7sQ****

Operation

string

DashVector 資料庫操作類型。

Upsert

Network

string

網路類型。

PublicNetwork

PrimaryKeyId

object

插入/刪除記錄時的主鍵 ID 不填寫此欄位時,使用隨機主鍵 ID。

Form

string

轉換的格式。

JSONPATH

Value

string

  • Form 為 JSONPATH:JSONPath 提取內容

  • Form 為 TEMPLATE:模板變數

註:Value 欄位不允許超過 10240 個字元。

$.data.requestId

Template

string

主鍵 ID 模板,僅當 Form 是 TEMPLATE 時需要填寫。

${ID}

Partition

object

Partition(分區),預設值為 default 分區。

Form

string

轉換的格式。

CONSTANT

Value

string

  • Form 為 CONSTANT:常量值

  • Form 為 JSONPATH:JSONPath 提取內容

註:Value 欄位不允許超過 10240 個字元。

default

Template

string

Vector

object

插入 DashVector 記錄的向量。

Form

string

轉換的格式。

JSONPATH

Value

string

JSONPath 提取內容。

註:Value 欄位不允許超過 10240 個字元。

$.data.messageBody

Template

string

DashVectorSchemaParameters

array<object>

插入 DashVector 時表項的 Schema 欄位定義,事件內容轉換後結果必須是 JSON 格式。

array<object>

Name

object

Form

string

Value

string

Template

string

Type

object

Form

string

Value

string

Template

string

Value

object

Form

string

Value

string

Template

string

SinkOpenSourceRabbitMQParameters

object

Sink Open Source RabbitMQ 參數。

Endpoint

string

RabbitMQ 執行個體存取點。

192.168.1.1:9876

VirtualHostName

string

RabbitMQ 的虛擬機器主機名稱。

Vhost1

TargetType

string

目標類型。

exchange

Exchange

string

用於訊息路由的交換器名稱。

my_exchange

QueueName

string

用於儲存訊息的隊列名稱。

my_queue

Username

string

用於身分識別驗證的使用者名稱。

admin

Password

string

用於身分識別驗證的使用者名稱密碼。

****

VpcId

string

VPC ID。

vpc-2zehizpoendb3****

VSwitchIds

string

交換器 ID。

vsw-wz9qqeovkwjxlu9uc****

SecurityGroupId

string

安全性群組 ID。

sg-2vcgdxz7o1n9zapp****

NetworkType

string

網路類型。

PrivateNetwork

AuthType

string

認證類型。

ACL

RoutingKey

object

訊息的路由規則。 僅當參數 TargetType 配置為 Exchange 時,需配置此參數。

Form

string

資料格式,預設為 JSONPATH。

JSONPATH

Value

string

訊息的路由規則。

housekeeping

Template

string

模板樣式。

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

Body

object

訊息內容。

Form

string

轉換的格式。

TEMPLATE

Value

string

轉換前的值。

{ "key": "value" }

Template

string

模板樣式。

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

MessageId

object

訊息 ID。

Form

string

轉換的格式。

TEMPLATE

Value

string

轉換前的值。

{ "key": "value" }

Template

string

模板樣式。

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

Properties

object

過濾屬性。

Form

string

轉換的格式。

TEMPLATE

Value

string

轉換前的值。

{ "key": "value" }

Template

string

模板樣式。

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

SinkBaiLianParameters SinkBaiLianParameters

Sink BaiLian 參數。

SinkHttpsParameters

SinkHttpsParameters

Https 目標參數

SinkApiDestinationParameters SinkApiDestinationParameters

ApiDestination 目標參數

SinkOSSParameters SinkOSSParameters

SinkRabbitMQMetaParameters SinkRabbitMQMetaParameters

SinkRabbitMQMsgSyncParameters SinkRabbitMQMsgSyncParameters

SinkMQTTParameters SinkMQTTParameters

SinkAgentRunParameters SinkAgentRunParameters

RunOptions

object

運行環境參數。

MaximumTasks

integer

並發數。

2

RetryStrategy

object

事件推送失敗時的重試策略。

PushRetryStrategy

string

重試策略:BACKOFF_RETRY(退避重試)和 EXPONENTIAL_DECAY_RETRY(指數衰減重試)。

EXPONENTIAL_DECAY_RETRY

ErrorsTolerance

string

異常容忍策略:NONE(不容忍異常)、ALL(容忍所有異常)。

ALL

DeadLetterQueue

object

是否啟用無效信件佇列。預設不啟用無效信件佇列,超過重試策略後的訊息將被丟棄。

Arn

string

無效信件佇列 ARN。

acs:ram::159787121179****:role/aliyunsaedefaultrole

Network

string

無效信件佇列的網路類型。

PrivateNetwork

VpcId

string

無效信件佇列所在的 VPC 網路識別碼。

vpc-2zehizpoendb3****

VSwitchIds

string

無效信件佇列所在的虛擬交換器 ID。

vsw-m5ev8asdc6h12345****

SecurityGroupId

string

無效信件佇列所在執行個體的安全性群組 ID。

sg-2vcgdxz7o1n9zapp****

BatchWindow

object

攢批視窗。

CountBasedWindow

integer

視窗中最大可容納的事件數目量。當達到此閾值,會觸發視窗內的資料往下遊推送。當存在多個視窗時,有一個視窗滿足即觸發。

100

TimeBasedWindow

integer

視窗中最大可容納的時間範圍內的事件(單位秒)。當達到此閾值,會觸發視窗內的資料往下遊推送。當存在多個視窗時,有一個視窗滿足即觸發。

10

BusinessOption

object

BusinessMode

string

MinCapacityUnitCount

integer

MaxCapacityUnitCount

integer

Throttling

integer

Status

string

擷取到的事件流的狀態。

RUNNING

Metadata

string

NextToken

string

用来表示当前调用返回读取到的位置,空代表数据已经读取完毕。下次调用时,需要将此设置到入参 NextToken 中。

177

Total

integer

总共记录数。

10

Code

string

接口返回码:

Success:表示成功。

其它:表示错误码。错误码详情,请参见错误码。

Success

Success

boolean

操作成功返回 true。

true

錯誤碼

HTTP status code

錯誤碼

錯誤資訊

描述

403 ServiceNotEnable Service not enable

訪問錯誤中心查看更多錯誤碼。

變更歷史

更多資訊,參考變更詳情