すべてのプロダクト
Search
ドキュメントセンター

EventBridge:ListEventStreamings

最終更新日:Jun 17, 2026

イベントストリーミングをクエリします。

操作説明

イベントストリーミングをクエリします。

今すぐお試しください

この API を OpenAPI Explorer でお試しください。手作業による署名は必要ありません。呼び出しに成功すると、入力したパラメーターに基づき、資格情報が組み込まれた SDK コードが自動的に生成されます。このコードをダウンロードしてローカルで使用できます。

テスト

RAM 認証

下表に、この API を呼び出すために必要な認証情報を示します。認証情報は、RAM (Resource Access Management) ポリシーを使用して定義できます。以下で各列名について説明します。

  • アクション:特定のリソースに対して実行可能な操作。ポリシー構文ではAction要素として指定します。

  • API:アクションを具体的に実行するための API。

  • アクセスレベル:各 API に対して事前定義されているアクセスの種類。有効な値:create、list、get、update、delete。

  • リソースタイプ:アクションが作用するリソースの種類。リソースレベルでの権限をサポートするかどうかを示すことができます。ポリシーの有効性を確保するため、アクションの対象として適切なリソースを指定してください。

    • リソースレベルの権限を持つ API の場合、必要なリソースタイプはアスタリスク (*) でマークされます。ポリシーのResource要素で対応する ARN を指定してください。

    • リソースレベルの権限を持たない API の場合、「すべてのリソース」と表示され、ポリシーのResource要素でアスタリスク (*) でマークされます。

  • 条件キー:サービスによって定義された条件のキー。このキーにより、きめ細やかなアクセス制御が可能になります。この制御は、アクション単体に適用することも、特定のリソースに対するアクションに適用することもできます。Alibaba Cloud は、サービス固有の条件キーに加えて、すべての RAM 統合サービスに適用可能な一連の共通条件キーを提供しています。

  • 依存アクション:ある特定のアクションを実行するために、前提として実行が必要となる他のアクション。依存アクションの権限も RAM ユーザーまたは RAM ロールに付与する必要があります。

アクション

アクセスレベル

リソースタイプ

条件キー

依存アクション

eventbridge:ListEventStreamings

list

*EventStreaming

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

なし なし

リクエストパラメーター

パラメーター

必須 / 任意

説明

NamePrefix

string

任意

イベントストリーミングの名前プレフィックス。

name

Limit

integer

任意

リクエストごとに返すエントリの最大数。このパラメーターとNextTokenを組み合わせてページネーションを行うことができます。

重要 リクエストごとのエントリの最大数は100を超えることはできません。

10

NextToken

string

任意

結果の次のページを取得するために使用されるトークン。Limitパラメーターが指定され、追加の結果が存在する場合、このパラメーターが返されます。

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

リクエストID。

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

Data

object

イベントストリーミングのリスト。

EventStreamings

array<object>

イベントストリーミングのリスト。

array<object>

イベントストリーミングエンティティ。

EventStreamingName

string

イベントストリームの名前。

name

Description

string

イベントストリームの説明。

demo

Source

object

イベントソース。

SourceMNSParameters

object

MNS ソース。

RegionId

string

リージョン ID。

cn-zhangjiakou

QueueName

string

MNS キューの名前。

work4

IsBase64Decode

boolean

Base64 デコードが有効になっているかどうかを指定します。

true

SourceRabbitMQParameters

object

RabbitMQ ソース。

RegionId

string

リージョン ID。

cn-zhangjiakou

InstanceId

string

RabbitMQ インスタンスの ID。

dbaudit-cn-7mz2hqo****

VirtualHostName

string

RabbitMQ インスタンスの vhost の名前。

eb-connect

QueueName

string

RabbitMQ インスタンス内のキューの名前。

liuyang

SourceRocketMQParameters

object

RocketMQ ソース。

RegionId

string

RocketMQ インスタンスのリージョン ID。

cn-chengdu

InstanceId

string

RocketMQ インスタンスの ID。

i-f8zbher64dlm58pl****

Topic

string

メッセージトピック。

topic_add_anima

Tag

string

メッセージフィルタリングタグ。

v1

Offset

string

コンシューマオフセット。有効な値: CONSUMEFROMLASTOFFSET:最新のオフセットからメッセージの消費を開始します。 CONSUMEFROMFIRSTOFFSET:最も早いオフセットからメッセージの消費を開始します。 CONSUMEFROMTIMESTAMP:特定のタイムスタンプからメッセージの消費を開始します。

CONSUMEFROMTIMESTAMP

GroupID

string

RocketMQ インスタンスのグループ ID。

GID_group1

Timestamp

integer

タイムスタンプ。このパラメーターは、Offset を CONSUMEFROMTIMESTAMP に設定した場合にのみ有効です。

1670742074043

InstanceType

string

インスタンスタイプ。有効な値:

  • Cloud_4:Alibaba Cloud RocketMQ 4.0 インスタンス (デフォルト)

  • Cloud_5:Alibaba Cloud 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

VPC の ID。

vpc-bp1a4gmlk31hy***l3ss

InstanceVSwitchIds

string

インスタンスの vSwitch 情報。

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

vSwitch ID。

vsw-m5ev8asdc6h12345****

SecurityGroupId

string

セキュリティグループ ID。

sg-m5edtu24f12345****

SourceRocketMQCheckpointParameters

object

RocketMQ チェックポイントソース。

RegionId

string

リージョン ID。

cn-hangzhou

InstanceType

string

RocketMQ インスタンスのタイプ。

Cloud_5

InstanceId

string

RocketMQ インスタンスの ID。

rmq-cn-jte3w******

Topics

array

RocketMQ インスタンスのトピック。

string

RocketMQ インスタンスのトピック。

myTopic

SourceApacheRocketMQCheckpointParameters

object

Apache RocketMQ チェックポイントソース。

RegionId

string

リージョン ID。

cn-hangzhou

Topics

array

Apache RocketMQ インスタンスのトピック。

string

Apache RocketMQ インスタンスのトピック。

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

vSwitch ID。

vsw-dwaafds****

SecurityGroupId

string

セキュリティグループ ID。

sg-mw43*****

SourceKafkaParameters

object

Kafka ソース。

RegionId

string

インスタンスのリージョン ID。

cn-chengdu

InstanceId

string

インスタンス ID。

bastionhost-cn-i7m2gwt****

Topic

string

トピック名。

topic_empower_1642473600414

ConsumerGroup

string

トピックをサブスクライブするコンシューマーグループの ID。

GID_TEST

OffsetReset

string

オフセット。

latest

Network

string

ネットワークタイプ。デフォルト値:Default。インスタンスが VPC 内にある場合、値は PublicNetwork です。

Default

VpcId

string

ユーザーの VPC ID。

vpc-wz9ki1qdlx3cx5cbf****

VSwitchIds

string

vSwitch ID。

vsw-bp1rmi8rind7eo50c****

SecurityGroupId

string

セキュリティグループ ID。

sg-5ud5f3p0rqqis69****eho7cp

ValueDataType

string

メッセージ本文のエンコード形式。有効な値:

  • JSON

  • Text

  • Binary

JSON

SourceMQTTParameters

object

MQTT ソース。

RegionId

string

リージョン ID。

cn-qingdao

InstanceId

string

インスタンス ID。

bastionhost-cn-zvp27kc****

Topic

string

トピック名。

migration_instance

BodyDataType

string

メッセージのエンコード形式。有効な値:

  • JSON

  • Text

  • Binary

JSON

NetworkType

string

ネットワークタイプ。

VpcId

string

VPC ID。

VSwitchIds

string

vSwitch ID。

SecurityGroupId

string

セキュリティグループ ID。

SourceDTSParameters

object

DTS ソース。

TaskId

string

タスク ID。

1611b337285f44e2936a2c4170****

BrokerUrl

string

変更追跡チャンネルのネットワークアドレスとポート番号。

Topic

string

変更追跡チャンネルのサブスクリプショントピック。

TP_TEST_UNDERWRITE_ISSUE

Sid

string

コンシューマーグループ ID。

HG9

Username

string

コンシューマーグループのアカウント。

admin

Password

string

コンシューマーグループアカウントのパスワード。

123456

InitCheckPoint

string

コンシューマオフセット。これは、SDK クライアントが最初のデータ入力を消費するときの UNIX タイムスタンプです。

1620962769

SourceSLSParameters

object

SLS ソース。

Project

string

SLS のプロジェクト。

dmmzk

LogStore

string

SLS の Logstore。

waf-logstore

ConsumerGroup

string

トピックをサブスクライブするコンシューマーグループの ID。

go-dts-shelf-group

ConsumePosition

string

コンシューマオフセット。有効な値は begin、end、または秒単位の UNIX タイムスタンプです。

begin

RoleName

string

EventBridge に SLS からのログ読み取り権限を付与する RAM ロールの名前。RAM コンソールでこのロールを作成する際、信頼できるエンティティとして **Alibaba Cloud Service** を選択し、信頼できるサービスとして **EventBridge** を設定します。

testRole

SourcePrometheusParameters

object

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 パッケージのダウンロード URL。

"https://examplebucket.oss-cn-hangzhou.aliyuncs.com/testDoc/Old_Homebrew/2024-06-26%2022%3A34%3A08/opt/homebrew/homebrew/Library/Homebrew/test/support/fixtures/cask/AppWithBinary.zip?OSSAccessKeyId=ri&Expires=1725539627&Signature=rb8q3OpV2i3gZJ"

ConnectorParameters

object

コネクタパラメーター。

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

OSS イベントソース。

RoleName

string

EventBridge に OSS からのファイル読み取りを許可するロールの名前。このロールには、少なくとも OSS に対する読み取り専用権限が必要です。

eventbridge_oss_role

BucketName

string

OSS のバケット名。

bucket_abc

Prefix

string

ファイルパスのプレフィックス。

fun/document/

LoadMode

string

データロードモード。`single` は単一のドキュメントをロードします。`element` はドキュメントをチャンクでロードします。有効な値:`single` および `element`。デフォルト値:`single`。

single

LoadFormat

string

ドキュメントローダー。

TextLoader

Delimiter

string

チャンクローディングモードで使用される区切り文字。デフォルトの区切り文字は改行文字 (` `) です。

\n

SourceOpenSourceRabbitMQParameters

object

オープンソース 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

vSwitch ID。

vsw-m5ev8asdc6h12345****

SecurityGroupId

string

セキュリティグループ ID。

sg-m5edtu24f12345****

NetworkType

string

ネットワークタイプ。

PrivateNetwork

AuthType

string

認証タイプ。

ACL

SourceEventBusParameters

object

EventBridge ソース。

EventBusName

string

イベントバス名。

my-event-bus

EventRuleName

string

イベントルール名。

my-event-rule

SourceMySQLParameters SourceMySQLParameters

MySQL ソース。

SourcePostgreSQLParameters SourcePostgreSQLParameters

SourceRabbitMQMetaParameters SourceRabbitMQMetaParameters

SourceRabbitMQMsgSyncParameters SourceRabbitMQMsgSyncParameters

SourceFeiShuDocsParameters SourceFeiShuDocsParameters

FilterPattern

string

イベントフィルターパターン。パターンが指定されていない場合、すべてのイベントが一致します。

Transforms

array<object>

変換の構成。

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

ターゲットサービスは Simple Message Queue (旧称:MNS) です。

Value

string

MNS キューの名前。

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

Base64 エンコーディングを有効にするかどうかを指定します。

Value

string

Base64 エンコーディングが有効になっているかどうかを示します。

true

Form

string

変換フォーマット。デフォルト値:CONSTANT。

CONSTANT

Template

string

適用されません。

SinkEventHouseParameters

object

イベントターゲットの名前。

CatalogName

string

カタログの名前。

cat1

NamespaceName

string

名前空間の名前。

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

RabbitMQ シンクのパラメーター。

InstanceId

object

ターゲットサービスは Message Queue for 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

インスタンスのキューの名前。

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

Kafka シンクパラメーター。

InstanceId

object

ターゲットサービスは Message Queue for 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` と `topics` の両方が指定されている場合、`topics` が優先されます。以下のモードがサポートされています: 1. **静的定数モード**:固定のトピック名(例:「order_created」)を指定します。すべてのメッセージがこのトピックに送信されます。 2. **動的抽出モード**:標準の JSONPath 式(例:「$.user.id」または「$.metadata.category」)を指定します。システムはアップストリームメッセージを解析し、抽出された値をトピック名として使用します。

Value

string

値。

Form

string

変換タイプ。有効な値: CONSTANT:固定値。 JSONPATH:指定されたパスに基づいてアップストリームメッセージから値を抽出します。

Template

string

テンプレート。

Acks

object

Kafka へのデータ書き込みの確認モード:

  • acks=0:サーバーは応答を送信しません。このモードは高性能ですが、データ損失のリスクが高いです。

  • acks=1:データがプライマリノードに書き込まれた後、サーバーは応答を送信します。このモードは中程度の性能で、データ損失のリスクも中程度です。プライマリノードが停止するとデータが失われる可能性があります。

  • acks=all:データがプライマリノードに書き込まれ、すべてのセカンダリノードに同期された後にのみ、サーバーは応答を送信します。このモードは低性能ですが、高いデータセキュリティを保証します。データは、プライマリノードとすべてのセカンダリノードが停止した場合にのみ失われます。

Value

string

Kafka へのデータ書き込みの確認モード:

  • acks=0:サーバーは応答を送信しません。このモードは高性能ですが、データ損失のリスクが高いです。

  • acks=1:データがプライマリノードに書き込まれた後、サーバーは応答を送信します。このモードは中程度の性能で、データ損失のリスクも中程度です。プライマリノードが停止するとデータが失われる可能性があります。

  • acks=all:データがプライマリノードに書き込まれ、すべてのセカンダリノードに同期された後にのみ、サーバーは応答を送信します。このモードは低性能ですが、高いデータセキュリティを保証します。データは、プライマリノードとすべてのセカンダリノードが停止した場合にのみ失われます。

1

Form

string

変換フォーマット。デフォルト値:CONSTANT。

CONSTANT

Template

string

サポートされていません。

Key

object

メッセージの ID。

Value

string

メッセージの ID を指定します。

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

RocketMQ シンク。

InstanceId

object

ターゲットサービスは Message Queue for Apache RocketMQ です。

Value

string

RocketMQ インスタンスの ID。

MQ_INST_164901546557****_BAAN****

Form

string

変換フォーマット。デフォルト値:CONSTANT。

CONSTANT

Template

string

利用可能な説明はありません。

Topic

object

RocketMQ インスタンスのトピック。

Value

string

RocketMQ インスタンスのトピック。

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:Alibaba Cloud RocketMQ 4.0 インスタンス (デフォルト)

  • Cloud_5:Alibaba Cloud 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

vSwitch ID。

Value

string

vSwitch 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

シンク RocketMQ チェックポイントパラメーター。

InstanceType

string

RocketMQ のインスタンスタイプ。

Cloud_5

InstanceId

string

RocketMQ インスタンス ID。

MQ_INST_1825725063814405_BZ******

Topic

object

RocketMQ インスタンスのトピック。

Value

string

トピックの名前。

myTopic

Form

string

変換フォーマット。デフォルト値:CONSTANT。

CONSTANT

Template

string

テンプレートのフォーマット。

Group

object

RocketMQ のコンシューマーグループ。

Value

string

コンシューマーグループのグループ ID。

GID_******

Form

string

変換フォーマット。デフォルト値:CONSTANT。

CONSTANT

Template

string

テンプレートのフォーマット。

ConsumeTimestamp

object

コンシューマオフセット。

Value

string

タイムスタンプ。

1636597951964

Form

string

変換フォーマット。デフォルト値:CONSTANT。

CONSTANT

Template

string

テンプレートのフォーマット。

SinkApacheRocketMQCheckpointParameters

object

シンク Apache RocketMQ チェックポイントパラメーター。

Topic

object

Apache RocketMQ インスタンスのトピック名。

Value

string

トピックの名前。

myTopic

Form

string

変換フォーマット。デフォルト値:CONSTANT。

CONSTANT

Template

string

テンプレートのフォーマット。

Group

object

Apache RocketMQ のコンシューマーグループに関する情報。

Value

string

コンシューマーグループのグループ 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

vSwitch ID。

vsw-wz9qqeovkwjxlu9uc****

SecurityGroupId

string

セキュリティグループ ID。

sg-2vcgdxz7o1n9zapp****

SinkSLSParameters

object

SLS シンクのパラメーター。

Project

object

SLS プロジェクト。

Value

string

SLS プロジェクト。

test-project

Form

string

変換フォーマット。デフォルト値:CONSTANT。

CONSTANT

Template

string

このパラメーターは使用されません。

LogStore

object

SLS Logstore。

Value

string

SLS Logstore。

test-logstore

Form

string

変換フォーマット。デフォルト値:CONSTANT。

CONSTANT

Template

string

このパラメーターは使用されません。

Topic

object

ログのトピック。これは SLS の予約フィールド `topic` に対応します。

Value

string

ログのトピック。これは 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 ロールの名前。RAM コンソールでこのロールを作成する際、信頼できるエンティティとして **Alibaba Cloud Service** を選択し、信頼できるサービスとして **EventBridge** を設定します。

Value

string

EventBridge に SLS ログコンテンツの読み取りを許可するには、RAM コンソールでロールを作成します。このロールでは、Alibaba Cloud Service を選択し、信頼できるサービスを EventBridge に設定します。

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

シンク 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

DataHub シンクパラメーター。

Project

object

DataHub プロジェクト名。

Value

string

DataHub プロジェクト名。

demo-project

Form

string

変換フォーマット。デフォルト値:CONSTANT。

CONSTANT

Template

string

サポートされていません。

Topic

object

DataHub トピックの名前。

Value

string

DataHub トピックの名前。

demo-topic

Form

string

変換フォーマット。デフォルト値:CONSTANT。

CONSTANT

Template

string

このパラメーターは使用されません。

TopicType

object

トピックタイプ。有効な値:

  • TUPLE

  • BLOB

Value

string

DataHub トピックのタイプ。有効な値:

  • TUPLE

  • BLOB

TUPLE

Form

string

変換フォーマット。デフォルト値:CONSTANT。

CONSTANT

Template

string

サポートされていません。

TopicSchema

object

トピックのコンテンツパターン。タイプは TUPLE です。

Value

string

TUPLE タイプのトピックのコンテンツパターン。

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

Form

string

変換フォーマット。デフォルト値:CONSTANT。

CONSTANT

Template

string

適用されません。

Body

object

レコードコンテンツのテンプレート。データ型は BLOB です。

Value

string

BLOB レコードのコンテンツのテンプレート。

Form

string

変換フォーマット。

ORIGINAL

Template

string

適用されません。

RoleName

object

EventBridge に SLS からのログ読み取り権限を付与する RAM ロールの名前。RAM コンソールでこのロールを作成する際、信頼できるエンティティとして **Alibaba Cloud Service** を選択し、信頼できるサービスとして **EventBridge** を設定します。

Value

string

EventBridge に SLS ログコンテンツの読み取りを許可するには、RAM コンソールでロールを作成します。このロールでは、Alibaba Cloud Service を選択し、信頼できるサービスを EventBridge に設定します。

testRole

Form

string

変換フォーマット。デフォルト値:CONSTANT。

CONSTANT

Template

string

このパラメーターは使用されません。

SinkCustomizedKafkaParameters

object

Kafka のシンクパラメーター。

InstanceId

string

Kafka インスタンスの ID。

90be1f96-4229-4535-bb76-34b4f6fb2b71

SinkCustomizedKafkaConnectorParameters

object

シンク 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 パッケージ内のプロパティファイルを解析した結果。

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

DashVector シンクパラメーター。

InstanceId

string

インスタンス ID。

vrs-cn-lbj3ru1***

Collection

string

コレクションの名前。

collection1

ApiKey

string

DashVector コンソールで作成された API キー。

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

パーティション。デフォルト値はデフォルトパーティションです。

Form

string

変換フォーマット。

CONSTANT

Value

string

  • Form が CONSTANT の場合:定数値。

  • Form が JSONPATH の場合:JSONPath を使用してフェッチするコンテンツ。

注:Value フィールドは 10,240 文字を超えることはできません。

default

Template

string

値は返されません。

Vector

object

DashVector に挿入するレコードのベクター。

Form

string

変換フォーマット。

JSONPATH

Value

string

JSONPath によって抽出されたコンテンツ。

注:Value フィールドは 10,240 文字を超えることはできません。

$.data.messageBody

Template

string

サポートされていません。

DashVectorSchemaParameters

array<object>

DashVector に挿入されるテーブルエントリのフィールドのスキーマ定義。変換されたイベントコンテンツは 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

オープンソース RabbitMQ シンクのパラメーター。

Endpoint

string

RabbitMQ インスタンスのエンドポイント。

192.168.1.1:9876

VirtualHostName

string

RabbitMQ 仮想ホストの名前。

Vhost1

TargetType

string

ターゲットタイプ。

exchange

Exchange

string

メッセージルーティングに使用される exchange の名前。

my_exchange

QueueName

string

メッセージを保存するために使用されるキューの名前。

my_queue

Username

string

本人確認のためのユーザー名。

admin

Password

string

本人確認のためのパスワード。

****

VpcId

string

VPC ID。

vpc-2zehizpoendb3****

VSwitchIds

string

vSwitch 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

シンク BaiLian パラメーター。

SinkHttpsParameters

SinkHttpsParameters

HTTPS ターゲットパラメーター。

SinkApiDestinationParameters SinkApiDestinationParameters

API 宛先ターゲットパラメーター。

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 の ID。

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 ステータスコード

エラーコード

エラーメッセージ

説明

403 ServiceNotEnable Service not enable

完全なリストについては、「エラーコード」をご参照ください。

変更履歴

完全なリストについては、「変更履歴」をご参照ください。