查詢事件流。
介面說明
查詢事件流。
調試
您可以在OpenAPI Explorer中直接運行該介面,免去您計算簽名的困擾。運行成功後,OpenAPI Explorer可以自動產生SDK程式碼範例。
調試
授權資訊
|
操作 |
存取層級 |
資源類型 |
條件關鍵字 |
關聯操作 |
|
eventbridge:ListEventStreamings |
list |
*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 |
| 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 |
| BodyDataType |
string |
訊息編碼格式:
|
JSON |
| Network |
string |
網路類型。
|
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 |
| SourceMQTTParameters |
object |
Source MQTT 源。 |
|
| RegionId |
string |
地區 ID。 |
cn-qingdao |
| InstanceId |
string |
執行個體 id。 |
bastionhost-cn-zvp27kc**** |
| Topic |
string |
Topic 名稱。 |
migration_instance |
| BodyDataType |
string |
訊息編碼格式:
|
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 |
同步或則非同步。
|
|
| Value |
string |
同步或則非同步。
|
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 確認模式:
|
|
| Value |
string |
寫入 Kafka 確認模式:
|
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 |
| 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 |
網路類型。
|
|
| Value |
string |
網路類型。
|
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 資料格式。可選擇預設或者配置制定的索引值:
|
|
| Value |
string |
SLS 資料格式。可選擇預設或者配置制定的索引值:
|
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 類型:
|
|
| Value |
string |
topic 類型:
|
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 |
註:Value 欄位不允許超過 10240 個字元。 |
$.data.requestId |
| Template |
string |
主鍵 ID 模板,僅當 Form 是 TEMPLATE 時需要填寫。 |
${ID} |
| Partition |
object |
Partition(分區),預設值為 default 分區。 |
|
| Form |
string |
轉換的格式。 |
CONSTANT |
| Value |
string |
註: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 |
訪問錯誤中心查看更多錯誤碼。
變更歷史
更多資訊,參考變更詳情。