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

EventBridge:GetEventStreaming

最終更新日:Jun 29, 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:GetEventStreaming

get

*EventStreaming

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

なし なし

リクエストパラメーター

パラメーター

必須 / 任意

説明

EventStreamingName

string

必須

クエリするイベントストリームの名前。

myeventstreaming

レスポンスフィールド

フィールド

説明

object

応答パラメーター。

Message

string

エラーメッセージ。

The event streaming [xxxx] not existed!

RequestId

string

リクエスト ID。

7892F480-58C9-5067-AB35-8A7BEF****

Data

object

返されたデータ。

EventStreamingName

string

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

rocketmq-sync

Description

string

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

RocketMQ-to-RocketMQ

Source

object

イベントソース。

SourceMNSParameters

object

Simple メッセージキュー (旧 MNS) ソースのパラメーター。

RegionId

string

リージョン ID。

cn-hangzhou

QueueName

string

Simple メッセージキュー (旧 MNS) インスタンスのキュー名。

demo

IsBase64Decode

boolean

Base64 デコードが有効かどうかを示します。

true

SourceRabbitMQParameters

object

RabbitMQ ソースのパラメーター。

RegionId

string

リージョン ID。

cn-hangzhou

InstanceId

string

ApsaraMQ for RabbitMQ メッセージキューインスタンスのインスタンス ID。

i-f8z9a9mcgwri1c1i****

VirtualHostName

string

ApsaraMQ for RabbitMQ メッセージキューインスタンスのバーチャルホスト名。

eb-connect

QueueName

string

ApsaraMQ for RabbitMQ メッセージキューインスタンスのキュー名。

comp

SourceRocketMQParameters

object

RocketMQ ソースのパラメーター。

RegionId

string

ApsaraMQ for RocketMQ メッセージキューインスタンスのリージョン ID。

cn-hangzhou

InstanceId

string

ApsaraMQ for RocketMQ メッセージキューインスタンスのインスタンス ID。

i-f8zbher64dlm58pl****

Topic

string

メッセージの Topic。

topic_add_anima

Tag

string

メッセージのフィルタータグ。

v1

Offset

string

メッセージの消費オフセット。有効な値: CONSUME_FROM_LAST_OFFSET: 最大オフセットから消費を開始します。 CONSUME_FROM_FIRST_OFFSET: 最小オフセットから消費を開始します。 CONSUME_FROM_TIMESTAMP: 指定した時間のオフセットから消費を開始します。

CONSUMEFROMLASTOFFSET

GroupID

string

ApsaraMQ for RocketMQ メッセージキューインスタンスのグループ ID。

GID_group1

Timestamp

integer

タイムスタンプ。このパラメーターは Offset パラメーターが CONSUME_FROM_TIMESTAMP に設定されている場合にのみ有効です。

1636597951964

InstanceType

string

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

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

  • Cloud_5: ApsaraMQ for RocketMQ 5.0 インスタンス

  • SelfBuilt: セルフマネージド Apache RocketMQ クラスター

Cloud_4

InstanceEndpoint

string

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

reg****-vpc.cn-zhangjiakou.aliyuncs.com

AuthType

string

認証タイプ。

ACL

InstanceUsername

string

インスタンスのユーザー名。

xxxa

InstancePassword

string

インスタンスのパスワード。

xxxa

InstanceVpcId

string

インスタンスの VPC ID。

vpc-m5e3sv4b12345****

InstanceVSwitchIds

string

インスタンスの vSwitch ID。

vsw-m5ev8asdc6h12****

InstanceSecurityGroupId

string

インスタンスのセキュリティグループ ID。

sg-m5edtu24f12345****

InstanceNetwork

string

インスタンスのネットワークタイプ。有効な値:

  • PublicNetwork

  • PrivateNetwork

PublicNetwork

BodyDataType

string

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

  • Json

  • Text

  • Binary

Json

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****

Network

string

ネットワークタイプ。有効な値:

  • PublicNetwork

  • PrivateNetwork

PublicNetwork

SourceRocketMQCheckpointParameters

object

RocketMQ チェックポイントソースのパラメーター。

RegionId

string

リージョン ID。

cn-hangzhou

InstanceType

string

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

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

  • Cloud_5: ApsaraMQ for RocketMQ 5.0 インスタンス

  • SelfBuilt: セルフマネージド Apache RocketMQ クラスター

Cloud_4

InstanceId

string

インスタンス ID。

rmp-cn-jte3w******

Topics

array

メッセージの Topic。

string

メッセージの Topic。

opic_add_anima

SourceApacheRocketMQCheckpointParameters

object

RocketMQ チェックポイントソースのパラメーター。

RegionId

string

リージョン ID。

cn-hangzhou

InstanceId

string

RocketMQ インスタンス ID。

MQ_INST_164901546557****_BAAN****

Topics

array

Topic のリスト。

string

消費する Topic のリスト。

["Topic_1","Topic_2"]

InstanceEndpoint

string

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

registry-vpc.cn-hangzhou.aliyuncs.com

InstanceUsername

string

インスタンスのユーザー名。

admin

InstancePassword

string

インスタンスのパスワード。

123456

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-hangzhou

InstanceId

string

インスタンス ID。

i-bp1fbtrnqmjvgq66****

Topic

string

Topic 名。

topic_empower_1642473600414

ConsumerGroup

string

Topic をサブスクライブする消費者のグループ ID。

GID_TEST

OffsetReset

string

オフセット。

latest

Network

string

ネットワーク構成。デフォルト値: Default。VPC ネットワークの場合、このパラメーターを PublicNetwork に設定します。

Default

VpcId

string

VPC ID。

vpc-2zehizpoendb3****

VSwitchIds

string

vSwitch ID。

vsw-wz9qqeovkwjxlu9uc****

SecurityGroupId

string

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

sg-2vcgdxz7o1n9zapp****

ValueDataType

string

エンコードおよびデコードのフォーマット。有効な値:

  1. JSON: バイトが UTF-8 エンコーディングを使用して文字列にデコードされ、JSON として解析されます。

  2. Text: バイトが UTF-8 エンコーディングを使用して文字列にデコードされ、ペイロードに直接配置されます。

  3. Binary: バイトが Base64 エンコーディングを使用して文字列にエンコードされ、ペイロードに配置されます。

Text

SourceMQTTParameters

object

MQTT ソースのパラメーター。

RegionId

string

リージョン ID。

cn-shanghai

InstanceId

string

インスタンス ID。

i-2ze06wqdwk0uq14k****

Topic

string

Topic 名。

TOPIC-cainiao-pcs-wms-instock-noPrealertPrintLabel

BodyDataType

string

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

  • JSON

  • Text

  • Binary

JSON

NetworkType

string

ネットワークタイプ。

VpcId

string

VPC ID。

VSwitchIds

string

vSwitch ID。

SecurityGroupId

string

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

SourceDTSParameters

object

Data Transmission Service (DTS) ソースのパラメーター。

TaskId

string

タスク ID。

f86e5814-b223-482c-b768-3b873297****

BrokerUrl

string

データサブスクリプションチャンネルのネットワークアドレスとポート番号。

Topic

string

データサブスクリプションチャンネルのサブスクリプション Topic。

TP_TEST_UNDERWRITE_ISSUE

Sid

string

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

HD1

Username

string

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

admin

Password

string

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

admin****

InitCheckPoint

string

消費チェックポイント。SDK クライアントが最初のデータ Record を消費する時間のタイムスタンプです。値は UNIX タイムスタンプです。

1620962769

SourceSLSParameters

object

Simple Log Service (SLS) ソースのパラメーター。

Project

string

Simple Log Service プロジェクト。

dmmzk

LogStore

string

Simple Log Service の Logstore。

waf-logstore

ConsumerGroup

string

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

ConsumePosition

string

消費開始位置。最も古い位置または最新の位置を選択でき、それぞれ「begin」と「end」に対応します。秒単位で指定した時間から消費を開始することもできます。

begin

RoleName

string

イベントバス EventBridge に SLS ログコンテンツの読み取りを権限付与するロール名。Resource Access Management (RAM) コンソールでロールを作成する際、信頼できるエンティティとして Alibaba Cloud サービスを選択し、信頼できるサービスとしてイベントバスを選択します。

testRole

SourcePrometheusParameters

object

Prometheus イベントソースのパラメーター。

RegionId

string

リージョン ID。

cn-hangzhou

ClusterId

string

クラスター ID。

c83555068b6******ad213f565f209

DataType

string

データの型。

Json

Labels

string

ラベル。

__name__=.*

RoleName

string

タスクロール名。

test-role

ExternalLabels

string

イベントストリームに追加される外部ラベル。

{"env":"test"}

SourceCustomizedKafkaParameters

object

カスタム Kafka イベントソースのパラメーター。

InstanceId

string

Message Queue for Apache Kafka メッセージキューインスタンスのインスタンス ID。

r-8vb64581862c****

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

インスタンス構成。

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

SourceApacheKafkaParameters

object

Bootstraps

string

Topic

string

ConsumerGroup

string

OffsetReset

string

ValueDataType

string

VpcId

string

VSwitchIds

string

SecurityGroupId

string

NetworkType

string

SecurityProtocol

string

SaslMechanism

string

SaslUser

string

SaslPassword

string

SslTruststoreCertificates

string

[SSL 必須] Kafka サーバー信頼証明書。Kafka ブローカーの SSL 証明書を検証し、中間者攻撃を防止するために使用されます。フォーマット: Base64 エンコードされた PEM フォーマットで、通常は Kafka サーバーの CA 証明書またはサーバー証明書を含みます。例: CA 証明書の PEM ファイルコンテンツを Base64 エンコードします ('-----BEGIN CERTIFICATE-----' で始まり '-----END CERTIFICATE-----' で終わることを確認してください)。Kafka が自己署名証明書を使用している場合は、その証明書を発行した CA 証明書を提供してください。

SslKeystoreCertificateChain

string

[相互認証必須] Kafka クライアント証明書チェーン。Kafka サーバーが相互 SSL 認証を有効にしている場合に必須です (ssl.client.auth=required)。フォーマット: Base64 エンコードされた PEM フォーマットで、クライアント証明書と完全な証明書チェーン (クライアント証明書が最初、中間 CA 証明書が次、ルート CA 証明書はオプション) を含みます。注意: 各 PEM ファイルコンテンツが '-----BEGIN CERTIFICATE-----' で始まり '-----END CERTIFICATE-----' で終わることを確認し、連結されたコンテンツを Base64 エンコードしてください。

SslKeyPassword

string

[暗号化された秘密鍵に必須] Kafka クライアント秘密鍵パスワード。クライアント秘密鍵が暗号化されている場合に必須です (PEM ファイルに 'Proc-Type: 4,ENCRYPTED' または 'ENCRYPTED' マーカーが含まれている場合)。秘密鍵が暗号化されていない場合は空のままにしてください。注意: このパスワードは秘密鍵の復号にのみ使用され、Kafka 認証とは無関係です。

SslKeystoreKey

object

[双方向認証必須] SSL 秘密鍵構成オブジェクト。Kafka サーバーが双方向 SSL 認証を有効にしている場合に必須です。キーは KMS モードのみをサポートします: KmsArn を使用して秘密鍵を格納する Key Management Service (KMS) リソースを指定します。システムはセキュリティを高めるため、メモリ内でのみ KMS から秘密鍵コンテンツを取得します。構成例: {"KmsArn": "acs:kms:cn-hangzhou:123456789:secret/ssl-key-xxxx", "KmsSecretValueKey": "keystore_private_key"}

KmsArn

string

[必須] SSL 秘密鍵を格納する KMS リソース ARN。クライアント秘密鍵を格納する KMS インスタンスを特定するために使用されます。フォーマット例: 'acs:kms:cn-hangzhou:123456789:secret/ssl-keystore-key-xxxx'。KMS コンソールで対応するキーの ARN を確認できます。

KmsSecretValueKey

string

[KMS KV モード] KMS シークレット内のキー名。KMS シークレットがキーバリュー (KV) 構造で格納されている場合、このパラメーターを指定して SSL 秘密鍵に対応するキーを示します。例: KMS シークレットが '{"ssl_keystore_key":"-----BEGIN PRIVATE KEY-----...","ssl_truststore_key":"..."}' の場合、'ssl_keystore_key' を指定します。KMS シークレットがプレーンテキストモード (秘密鍵の PEM コンテンツを直接格納) の場合、このパラメーターは空のままにしてください。

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

オープンソース RabbitMQ インスタンスのエンドポイント。

192.168.1.100:5672

VirtualHostName

string

オープンソース RabbitMQ インスタンスのバーチャルホスト名。

eb-connect

QueueName

string

オープンソース RabbitMQ インスタンスのキュー名。

demo

BodyDataType

string

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

  • JSON

  • Text

  • Binary

Json

Username

string

ユーザー名。

admin

Password

string

パスワード。

******

VpcId

string

VPC ID。

vpc-bp1vllc1lnw1v657******

VSwitchIds

string

vSwitch ID。

vsw-uf65zhil5oukof5******

SecurityGroupId

string

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

sg-2ze65razphjfz3******

NetworkType

string

ネットワークタイプ。有効な値:

  • PublicNetwork

  • PrivateNetwork

PrivateNetwork

AuthType

string

認証タイプ。

ACL

SourceEventBusParameters

object

イベントバスソースのパラメーター。

EventBusName

string

イベントバスの名前。

demo

EventRuleName

string

イベントルールの名前。

test

SourceMySQLParameters SourceMySQLParameters

MySQL ソースのパラメーター。

SourcePostgreSQLParameters SourcePostgreSQLParameters

SourceRabbitMQMetaParameters SourceRabbitMQMetaParameters

SourceRabbitMQMsgSyncParameters SourceRabbitMQMsgSyncParameters

SourceFeiShuDocsParameters SourceFeiShuDocsParameters

Metadata

string

FilterPattern

string

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

Transforms

array<object>

イベント転換の構成。

object

クラウドリソースの Alibaba Cloud リソースネーム(ARN)。例えば、Function Compute の関数の ARN です。

Arn

string

クラウドリソースの Alibaba Cloud リソースネーム (ARN)。例: Function Compute の関数の ARN。

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

DashScopeTransformParameters

DashScopeTransformParameters

BaiLianAgentTransformParameters

BaiLianAgentTransformParameters

Sink

object

イベントターゲット。

SinkMNSParameters

object

Simple メッセージキュー (旧 MNS) イベントターゲット。

QueueName

object

ターゲットサービスタイプは Simple メッセージキュー (旧 MNS) です。

Value

string

Simple メッセージキュー (旧 MNS) インスタンスのキュー名。

MyQueue

Form

string

The transformation format. Default value: CONSTANT.

CONSTANT

Template

string

テンプレートスタイル。

Body

object

メッセージ本文。

Value

string

変換前の値。

{ "key": "value" }

Form

string

The transformation format.

TEMPLATE

Template

string

テンプレートスタイル。

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

IsBase64Encode

object

Base64 デコードが有効かどうかを示します。

Value

string

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

true

Form

string

The event transformation format. Default value: CONSTANT.

CONSTANT

Template

string

テンプレートスタイル。

SinkRabbitMQParameters

object

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

InstanceId

object

ターゲットサービスタイプは ApsaraMQ for RabbitMQ メッセージキューです。

Value

string

ApsaraMQ for RabbitMQ メッセージキューインスタンスのインスタンス ID。

e5c9b727-e06c-4d7e-84d5-f8ce644e****

Form

string

The transformation format. Default value: CONSTANT.

CONSTANT

Template

string

テンプレートスタイル。

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

VirtualHostName

object

ApsaraMQ for RabbitMQ メッセージキューインスタンスのバーチャルホスト名。

Value

string

ApsaraMQ for RabbitMQ メッセージキューインスタンスのバーチャルホスト名。

rabbit-host

Form

string

The transformation format. Default value: CONSTANT.

CONSTANT

Template

string

テンプレートスタイル。

TargetType

object

ターゲットタイプ。

Value

string

ターゲットタイプ。有効な値:

  • Exchange: Exchange モード。

  • Queue: Queue モード。

Exchange/Queue

Form

string

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

CONSTANT

Template

string

テンプレートスタイル。

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

Exchange

object

Exchange モード。 このパラメーターは TargetType が Exchange に設定されている場合にのみ必須です。

Value

string

メッセージキュー for RabbitMQ インスタンスの Exchange 名。

a_exchange

Form

string

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

CONSTANT

Template

string

テンプレートスタイル。

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

RoutingKey

object

メッセージのルーティングルール。 このパラメーターは TargetType が Exchange に設定されている場合に

Value

string

The routing rule of the message.

housekeeping

Form

string

The transformation format. Default value: CONSTANT.

CONSTANT

Template

string

テンプレートスタイル。

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

QueueName

object

Queue モード。 このパラメーターは TargetType が Queue に設定されている場合にのみ必須です。

Value

string

The name of the queue on the instance.

MyQueue

Form

string

The transformation format. Default value: CONSTANT.

CONSTANT

Template

string

テンプレートスタイル。

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

Body

object

メッセージ本文。

Value

string

The value before transformation.

{ "key": "value" }

Form

string

The transformation format.

TEMPLATE

Template

string

テンプレートスタイル。

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

MessageId

object

メッセージ ID。

Value

string

The value before transformation.

{ "key": "value" }

Form

string

The transformation format.

TEMPLATE

Template

string

テンプレートスタイル。

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

Properties

object

The filter properties.

Value

string

The value before transformation.

{ "key": "value" }

Form

string

The transformation format.

TEMPLATE

Template

string

テンプレートスタイル。

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

SinkFcParameters

object

関数ターゲット。

ServiceName

object

The service name.

Value

string

サービス名。

myService

Form

string

The transformation format. Default value: CONSTANT.

CONSTANT

Template

string

テンプレートスタイル。

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

FunctionName

object

The function name.

Value

string

The function name.

mFunction

Form

string

The transformation format. Default value: CONSTANT.

CONSTANT

Template

string

テンプレートスタイル。

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

Concurrency

object

The delivery concurrency. Minimum value: 1.

Value

string

配信の同時実行数。最小値: 1。

1

Form

string

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

CONSTANT

Template

string

テンプレートスタイル。

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

Qualifier

object

The service version.

Value

string

サービスバージョン。

LATEST

Form

string

The transformation format. Default value: CONSTANT.

CONSTANT

Template

string

テンプレートスタイル。

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

InvocationType

object

The invocation type. Valid values:

  • Sync: synchronous.

  • Async: asynchronous.

Value

string

The invocation type. Valid values:

  • Sync: synchronous.

  • Async: asynchronous.

Async

Form

string

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

CONSTANT

Template

string

テンプレートスタイル。

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

Body

object

関数に送信されるコンテンツ本文。

Value

string

変換前の値。

{ "key": "value" }

Form

string

変換フォーマット。有効な値:

  • ORIGINAL: 完全なイベント

  • JSONPATH: 部分イベント

  • CONSTANT: 定数

  • TEMPLATE: テンプレート

詳細については、イベント転換を参照してください。

TEMPLATE

Template

string

テンプレートスタイル。

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

DataFormat

object

イベントコンテンツのフォーマット変換ルール。

Value

string

The value before transformation.

{ "key": "value" }

Form

string

変換フォーマット。有効な値:

  • ORIGINAL: 完全なイベント

  • JSONPATH: 部分イベント

  • CONSTANT: 定数

  • TEMPLATE: テンプレート

JSONPATH

Template

string

テンプレートスタイル。

$.data.key

SinkKafkaParameters

object

The parameters for the Kafka sink.

InstanceId

object

The target service type is MSMQ for Apache Kafka.

Value

string

インスタンス ID。

Defaut_1283278472_s****

Form

string

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

CONSTANT

Template

string

テンプレートスタイル。

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

DynamicTopic

object

Specifies the target topic strategy for message routing. If both the topic parameter and the DynamicTopic parameter are specified, the DynamicTopic parameter takes precedence. Two configuration modes are supported: 1. Static constant mode: Specify a fixed topic name string (for example, "order_created"). All messages are sent to this topic. 2. Dynamic extraction mode: Specify a standard JSONPath expression (for example, "$.user.id" or "$.metadata.category"). The system parses the upstream message body and extracts the value of the matching field as the target topic name.

Value

string

The value.

Form

string

The transformation type. Valid values: CONSTANT: fixed value. JSONPATH: extracted from upstream based on the path.

Template

string

The template. [_single.resp.200.props.Data.Sink.SinkKafkaParameters.Topic

Topic

object

Topic 名。

Value

string

Topic 名。

test

Form

string

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

CONSTANT

Template

string

テンプレートスタイル。

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

CompressionType

string

Acks

object

Kafka への書き込み時の確認応答モード:

  • acks=0: サーバーからの応答は不要です。このモードはパフォーマンスが高いですが、データ損失のリスクが大きくなります。

  • acks=1: サーバーのプライマリノードがデータの書き込みに成功した後に応答が返されます。このモードはパフォーマンスとデータ損失のリスクが中程度です。プライマリノードがダウンした場合、データ損失が発生する可能性があります。

  • acks=all: プライマリノードがデータの書き込みに成功し、セカンダリノードが同期を完了した後にのみ応答が返されます。このモードはパフォーマンスが低いですが、データの安全性が高くなります。プライマリノードとセカンダリノードの両方がダウンした場合にのみデータ損失が発生します。

Value

string

Kafka への書き込み時の確認応答モード:

  • acks=0: サーバーからの応答は不要です。このモードはパフォーマンスが高いですが、データ損失のリスクが大きくなります。

  • acks=1: サーバーのプライマリノードがデータの書き込みに成功した後に応答が返されます。このモードはパフォーマンスとデータ損失のリスクが中程度です。プライマリノードがダウンした場合、データ損失が発生する可能性があります。

  • acks=all: プライマリノードがデータの書き込みに成功し、セカンダリノードが同期を完了した後にのみ応答が返されます。このモードはパフォーマンスが低いですが、データの安全性が高くなります。プライマリノードとセカンダリノードの両方がダウンした場合にのみデータ損失が発生します。

1

Form

string

The transformation format. Default value: CONSTANT.

CONSTANT

Template

string

テンプレートスタイル。

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

Key

object

メッセージキー。

Value

string

The message key.

key

Form

string

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

CONSTANT

Template

string

テンプレートスタイル。

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

Headers

object

The additional metadata of the Kafka message.

Value

string

The value before transformation.

{ "key": "value" }

Form

string

The transformation format. Valid values:

  • ORIGINAL: complete event

  • JSONPATH: partial event

  • CONSTANT: constant

  • TEMPLATE: template

CONSTANT

Template

string

テンプレートスタイル。

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

Value

object

メッセージ本文。

Value

string

変換前の値。

{ "key": "value" }

Form

string

The transformation format.

TEMPLATE

Template

string

テンプレートスタイル。

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

SinkApacheKafkaParameters

object

説明情報。

Bootstraps

string

Topic

string

DynamicTopic

object

メッセージルーティングのターゲット Topic 戦略を指定します。topic パラメーターと DynamicTopic パラメーターの両方が指定されている場合、DynamicTopic パラメーターが優先されます。2 つの構成モードがサポートされています: 1. 静的定数モード: 固定の Topic 名文字列を指定します (例: "order_created")。すべてのメッセージがこの Topic に送信されます。 2. 動的抽出モード: 標準の JSONPath 式を指定します (例: "$.user.id" または "$.metadata.category")。システムがアップストリームメッセージ本文を解析し、一致するフィールドの値をターゲット Topic 名として抽出します。

Value

string

The value.

Form

string

The transformation type. Valid values: CONSTANT: fixed value. JSONPATH: extracted from upstream based on the path.

Template

string

The template. [_single.resp.200.props.Data.Sink.SinkKafkaParameters.Topic

Acks

string

CompressionType

string

Key

object

Value

string

Form

string

Template

string

Headers

object

Value

string

Form

string

Template

string

Value

object

Value

string

Form

string

Template

string

SecurityProtocol

string

SaslMechanism

string

SaslUser

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

NetworkType

object

Value

string

Form

string

Template

string

SaslPassword

string

SslTruststoreCertificates

string

[SSL 必須] Kafka サーバー信頼証明書。Kafka ブローカーの SSL 証明書の正当性を認証し、中間者攻撃を防止するために使用されます。フォーマット: Base64 エンコードされた PEM フォーマットで、通常は Kafka サーバーの CA 証明書またはサーバー証明書を含みます。例: CA 証明書の PEM ファイルコンテンツを Base64 エンコードします ('-----BEGIN CERTIFICATE-----' で始まり '-----END CERTIFICATE-----' で終わることを確認してください)。Kafka が自己署名証明書を使用している場合は、その証明書を発行した CA 証明書を提供してください。

SslKeystoreCertificateChain

string

[Required for mutual authentication] The Kafka client certificate chain. Required when the Kafka server enables mutual SSL authentication (ssl.client.auth=required). Format: Base64-encoded PEM format, containing the client certificate and the complete certificate chain (client certificate first, intermediate CA certificate next, root CA certificate optional). Note: Ensure each PEM file content starts with '-----BEGIN CERTIFICATE-----' and ends with '-----END CERTIFICATE-----', then Base64-encode the concatenated content.

SslKeyPassword

string

[Required for encrypted private key] The Kafka client private key password. Required when the client private key is encrypted (the PEM file contains 'Proc-Type: 4,ENCRYPTED' or 'ENCRYPTED' markers). Leave empty if the private key is not encrypted. Note: This password is used only to decrypt the private key and is unrelated to Kafka authentication.

SslKeystoreKey

object

[双方向認証必須] SSL 秘密鍵構成オブジェクト。Kafka サーバーが双方向 SSL 認証を有効にしている場合、クライアント秘密鍵が必要です。キーは KMS パターンのみをサポートします: KmsArn を使用して秘密鍵を格納する Key Management EPS リソースを指定します。システムはセキュリティを高めるため、メモリ内でのみ KMS から秘密鍵コンテンツを取得します。構成例: {"KmsArn": "acs:kms:ap-southeast-1:123456789:secret/ssl-key-xxxx", "KmsSecretValueKey": "keystore_private_key"}

KmsArn

string

[Required] The KMS resource ARN that stores the SSL private key. Used to locate the KMS instance that stores the client private key. Format example: 'acs:kms:cn-hangzhou:123456789:secret/ssl-keystore-key-xxxx'. You can view the ARN of the corresponding key in the KMS console.

KmsSecretValueKey

string

[KMS KV mode] The key name in the KMS secret. When the KMS secret is stored in a key-value (KV) structure, specify this parameter to indicate the key that corresponds to the SSL private key. Example: if the KMS secret is '{"ssl_keystore_key":"-----BEGIN PRIVATE KEY-----...","ssl_truststore_key":"..."}', specify 'ssl_keystore_key'. Leave this parameter empty if the KMS secret is in plain text mode (directly stores the PEM content of the private key).

SinkRocketMQParameters

object

シンク RocketMQ パラメーター。

InstanceId

object

The target service type is MSMQ for RocketMQ.

Value

string

The instance ID of the MSMQ for RocketMQ instance.

MQ_INST_164901546557****_BAAN****

Form

string

The transformation format. Default value: CONSTANT.

CONSTANT

Template

string

テンプレートスタイル。

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

Topic

object

The topic of the MSMQ for RocketMQ instance.

Value

string

メッセージキュー for RocketMQ インスタンスの Topic 名。

Mytopic

Form

string

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

CONSTANT

Template

string

テンプレートスタイル。

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

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

The filter properties.

Value

string

The value before transformation.

{ "key": "value" }

Form

string

変換フォーマット。

TEMPLATE

Template

string

テンプレートスタイル。

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

Tags

object

フィルタープロパティ。

Value

string

変換前の値。

{ "key": "value" }

Form

string

The transformation format.

TEMPLATE

Template

string

テンプレートスタイル。

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

InstanceType

object

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

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

  • Cloud_5: ApsaraMQ for RocketMQ 5.0 インスタンス

  • SelfBuilt: セルフマネージド Apache RocketMQ クラスター

Value

string

The instance type. Valid values:

  • Cloud_4: ApsaraMQ for RocketMQ 4.0 instance (default)

  • Cloud_5: ApsaraMQ for RocketMQ 5.0 instance

  • SelfBuilt: self-managed Apache RocketMQ cluster

Cloud_4

Form

string

The transformation format. Default value: CONSTANT.

CONSTANT

Template

string

None.

InstanceEndpoint

object

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

Value

string

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

vbr-8vbsvkkbpf3vb0zef****

Form

string

The transformation format. Default value: CONSTANT.

CONSTANT

Template

string

None.

InstanceUsername

object

インスタンスのユーザー名。

Value

string

インスタンスのユーザー名。

admin

Form

string

The transformation format. Default value: CONSTANT.

CONSTANT

Template

string

None.

InstancePassword

object

インスタンスのパスワード。

Value

string

インスタンスのパスワード。

admin****

Form

string

The transformation format. Default value: CONSTANT.

CONSTANT

Template

string

なし。

VpcId

object

VPC ID。

Value

string

VPC ID。

vbr-8vb835n3zf9shwlvb****

Form

string

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

CONSTANT

Template

string

None.

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

The transformation format. Default value: CONSTANT.

CONSTANT

Template

string

None.

Network

object

The network type. Valid values:

  • PublicNetwork

  • PrivateNetwork

Value

string

ネットワークタイプ。有効な値:

  • PublicNetwork

  • PrivateNetwork

PublicNetwork

Form

string

The transformation format. Default value: CONSTANT.

CONSTANT

Template

string

なし。

DeliveryOrderType

object

The delivery order type of messages. Optional. The default value is concurrent delivery.

Value

string

配信順序タイプ。有効な値:

  • Orderly: 順序付き配信。

  • Concurrently: 同時配信。

Concurrently

Form

string

The transformation format. Default value: CONSTANT.

CONSTANT

Template

string

テンプレートスタイル。

ShardingKey

object

メッセージのシャーディングキー。

説明
  • DeliveryOrderType が Orderly に設定されている場合、ShardingKey は必須です。

  • ソースが RocketMQ の場合、ShardingKey は空のままにできます。この場合、アップストリームの BrokerName と QueueId が連結されてメッセージの ShardingKey が生成されます。

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

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

  • Cloud_4: ApsaraMQ for RocketMQ 4.0 インスタンス。

  • Cloud_5: ApsaraMQ for RocketMQ 5.0 インスタンス。

Cloud_4

InstanceId

string

インスタンス ID。

MQ_INST_164901546557****_BAAN****

Topic

object

The topic of the MSMQ for RocketMQ instance.

Value

string

The topic name of the MSMQ for RocketMQ instance.

Mytopic

Form

string

The transformation format. Default value: CONSTANT.

CONSTANT

Template

string

テンプレートスタイル。

Group

object

The Group ID of the consumer group.

Value

string

Group ID

GID_EVENTBRIDGE_1736234******

Form

string

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

CONSTANT

Template

string

テンプレートスタイル。

ConsumeTimestamp

object

メッセージ消費のタイムスタンプ。

Value

string

The timestamp.

1570761026400

Form

string

The transformation format. Default value: CONSTANT.

CONSTANT

Template

string

テンプレートスタイル。

SinkApacheRocketMQCheckpointParameters

object

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

Topic

object

The topic of the RocketMQ instance.

Value

string

RabbitMQ インスタンスの Topic 名。

Mytopic

Form

string

The transformation format. Default value: CONSTANT.

CONSTANT

Template

string

テンプレートスタイル。

Group

object

The Group ID of the consumer group.

Value

string

Group ID

GID_EVENTBRIDGE_1736234******

Form

string

The transformation format. Default value: CONSTANT.

CONSTANT

Template

string

テンプレートスタイル。

ConsumeTimestamp

object

メッセージ消費のタイムスタンプ。

Value

string

The timestamp.

1570761026400

Form

string

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

CONSTANT

Template

string

テンプレートスタイル。

InstanceEndpoint

string

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

192.168.1.1:9876

InstanceUsername

string

The username required for authentication.

admin

InstancePassword

string

ユーザー名のパスワード。

****

NetworkType

string

ネットワークタイプ。

PrivateNetwork

VpcId

string

VPC ID。

vpc-2zeccak5pb0j3ay******

VSwitchId

string

vSwitch ID。

vsw-uf62oqt1twuevrt******

SecurityGroupId

string

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

sg-2ze5bmpw6adn0q******

SinkSLSParameters

object

Sink SLS Parameters

Project

object

Simple Log Service プロジェクト。

Value

string

The Simple Log Service project.

test-project

Form

string

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

CONSTANT

Template

string

テンプレートスタイル。

LogStore

object

The Simple Log Service Logstore.

Value

string

The Simple Log Service Logstore.

test-logstore

Form

string

The transformation format. Default value: CONSTANT.

CONSTANT

Template

string

テンプレートスタイル。

Topic

object

The topic where the log resides, corresponding to the Simple Log Service reserved field "topic".

Value

string

The topic where the log resides, corresponding to the Simple Log Service reserved field "topic".

testTopic

Form

string

The transformation format. Default value: CONSTANT.

CONSTANT

Template

string

テンプレートスタイル。

Body

object

The content sent to Simple Log Service.

Value

string

The value before transformation.

{ "key": "value" }

Form

string

The transformation format.

TEMPLATE

Template

string

テンプレートスタイル。

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

RoleName

object

To grant authorization to the event bus EventBridge to use this role to read Simple Log Service log content, the following condition must be met: when creating the role used by the service in the Resource Access Management (RAM) console, select "Alibaba Cloud Service" and set "Trusted Service" to "event bus".

Value

string

イベントバス EventBridge にこのロールを使用して Simple Log Service ログコンテンツの読み取りを権限付与するには、次の条件を満たす必要があります: Resource Access Management (RAM) コンソールでサービスが使用するロールを作成する際、「Alibaba Cloud サービス」を選択し、「信頼できるサービス」を「イベントバス」に設定します。

testRole

Form

string

The transformation format. Default value: CONSTANT.

CONSTANT

Template

string

テンプレートスタイル。

ContentType

object

Simple Log Service のデータ形式。デフォルトフォーマットを選択するか、指定されたキーバリューペアを構成できます。有効な値:

  • JSON

  • KeyValue

Value

string

The value before transformation.

JSON

Form

string

変換フォーマット。

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

Template

string

テンプレートスタイル。

SinkFnfParameters

object

The Sink CloudFlow parameters.

FlowName

object

フロー名。

Value

string

フロー名。

test-streaming-fnf

Form

string

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

CONSTANT

Template

string

テンプレートスタイル。

ExecutionName

object

実行名。

Value

string

The execution name.

123

Form

string

The transformation format. Default value: CONSTANT. Valid values:

  • JSONPATH: partial event.

  • CONSTANT: constant.

  • TEMPLATE: template.

For more information, see Event transformation.

CONSTANT

Template

string

テンプレートスタイル。

Input

object

The execution input information.

Value

string

実行入力情報。

123

Form

string

The transformation format. Default value: CONSTANT.

CONSTANT

Template

string

テンプレートスタイル。

RoleName

object

ロール構成。

Value

string

The role configuration.

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

Form

string

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

CONSTANT

Template

string

テンプレートスタイル。

SinkDataHubParameters

object

The Sink DataHub parameters.

Project

object

The DataHub project name.

Value

string

The DataHub project name.

demo-project

Form

string

The transformation format. Default value: CONSTANT.

CONSTANT

Template

string

None.

Topic

object

The DataHub topic name.

Value

string

DataHub Topic 名。

demo-topic

Form

string

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

CONSTANT

Template

string

None.

TopicType

object

Topic タイプ。有効な値:

  • TUPLE

  • BLOB

Value

string

The topic type. Valid values:

  • TUPLE

  • BLOB

TUPLE

Form

string

The transformation format. Default value: CONSTANT.

CONSTANT

Template

string

None.

TopicSchema

object

The topic content schema for the TUPLE type.

Value

string

The topic content schema for the TUPLE type.

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

Form

string

変換フォーマット。

TEMPLATE

Template

string

テンプレートスタイル。

{"k1":"${k1}","k2":"${k2}"}

Body

object

The Record content template for the BLOB type.

Value

string

BLOB タイプの Record コンテンツテンプレート。

Form

string

The transformation format.

ORIGINAL

Template

string

なし。

RoleName

object

タスクロール名。

Value

string

タスクロール名。

test-role

Form

string

The transformation format. Default value: CONSTANT.

CONSTANT

Template

string

None.

SinkCustomizedKafkaParameters

object

シンク Kafka パラメーター。

InstanceId

string

The instance ID of the MSMQ for Apache Kafka instance.

90be1f96-4229-4535-bb76-34b4f6fb****

SinkCustomizedKafkaConnectorParameters

object

シンク Kafka コネクタパラメーター。

ConnectorPackageUrl

string

The OSS file download 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=rb8q3OpV******"

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

Record の挿入または削除に使用するプライマリキー ID。このフィールドが指定されていない場合、ランダムなプライマリキー ID が使用されます。

Form

string

変換フォーマット。

JSONPATH

Value

string

  • If Form is JSONPATH: the content extracted by JSONPath.

  • If Form is TEMPLATE: the template variable.

Note: The Value field cannot exceed 10,240 characters.

$.data.requestId

Template

string

プライマリキー ID テンプレート。このパラメーターは Form が TEMPLATE に設定されている場合にのみ必須です。

${ID}

Partition

object

The partition. Default value: default.

Form

string

The transformation format.

CONSTANT

Value

string

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

  • Form が JSONPATH の場合: JSONPath で抽出されたコンテンツ。

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

default

Template

string

None.

Vector

object

DashVector に挿入する Record のベクター。

Form

string

The transformation format.

JSONPATH

Value

string

The content extracted by JSONPath.

Note: The Value field cannot exceed 10,240 characters.

$.data.messageBody

Template

string

None.

DashVectorSchemaParameters

array<object>

The schema field definition of the table entry when inserting into DashVector. The result of event content transformation must be in JSON format.

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 Parameters

Endpoint

string

The endpoint.

192.168.1.1:9876

VirtualHostName

string

The virtual host name of RabbitMQ.

vhost1

TargetType

string

メッセージ配信のターゲットタイプ。このパラメーターは TargetType が Exchange に設定されている場合にのみ有効です。

Exchange

Exchange

string

The exchange name in RabbitMQ.

my-exchange

QueueName

string

The queue name in RabbitMQ. This parameter takes effect only when TargetType is set to Queue.

my-queue

Username

string

RabbitMQ インスタンスにアクセスするためのユーザー名。

admin

Password

string

The password for accessing the RabbitMQ instance.

****

VpcId

string

VPC ID。

vpc-uf6of9452b2pba82c ****

VSwitchIds

string

vSwitch ID。

vsw-uf6of9452b2pba82c ****

SecurityGroupId

string

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

sg-uf6of9452b2pba82c ****

NetworkType

string

ネットワークタイプ。

PublicNetwork

AuthType

string

認証タイプ。

ACL

RoutingKey

object

The message routing key.

Form

string

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

CONSTANT

Value

string

The routing key value.

{"Form": "CONSTANT", "Value": "my-routing-key"}

Template

string

テンプレートスタイル。

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

Body

object

メッセージ本文コンテンツ。

Form

string

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

CONSTANT

Value

string

生データの値。

{"key": "value"}

Template

string

テンプレートスタイル。

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

MessageId

object

The unique identifier of the message.

Form

string

The transformation format. Default value: CONSTANT.

CONSTANT

Value

string

メッセージ ID の値。

12345

Template

string

テンプレートスタイル。

Properties

object

The additional properties of the message.

Form

string

The transformation format. Default value: CONSTANT.

CONSTANT

Value

string

The property content.

{"env": "prod"}

Template

string

テンプレートスタイル。

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

SinkBaiLianParameters SinkBaiLianParameters

Sink BaiLian Parameters

SinkDataWorksTriggerParameters SinkDataWorksTriggerParameters

SinkHttpsParameters

SinkHttpsParameters

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

SinkApiDestinationParameters SinkApiDestinationParameters

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

SinkOSSParameters SinkOSSParameters

SinkRabbitMQMetaParameters SinkRabbitMQMetaParameters

SinkRabbitMQMsgSyncParameters SinkRabbitMQMsgSyncParameters

SinkMQTTParameters SinkMQTTParameters

SinkAgentRunParameters SinkAgentRunParameters

RunOptions

object

The runtime environment parameters.

MaximumTasks

integer

同時実行数。

2

RetryStrategy

object

イベント配信失敗時のリトライポリシー。

PushRetryStrategy

string

リトライポリシー: BACKOFF_RETRY (バックオフ再試行) または EXPONENTIALDECAY_RETRY (指数関数的減衰リトライ)。

BACKOFF_RETRY

MaximumEventAgeInSeconds

number

最大再試行時間。

512

MaximumRetryAttempts

number

The maximum number of retry attempts.

2

ErrorsTolerance

string

フォールトトレランスポリシー: NONE (フォールトトレランスなし) または ALL (すべての例外を許容)。

ALL

DeadLetterQueue

object

Specifies whether to enable the dead-letter queue. By default, the dead-letter queue is disabled, and messages that exceed the retry policy are discarded.

Arn

string

デッドレターキューの ARN。

acs:ram::155020394332****:role/edskmstoecs

Network

string

デッドレターキューのネットワークタイプ。

PrivateNetwork

VpcId

string

デッドレターキューが存在する VPC ID。

vpc-2zehizpoendb3****

VSwitchIds

string

The vSwitch ID where the dead-letter queue resides.

vsw-m5ev8asdc6h12345****

SecurityGroupId

string

デッドレターキューが存在するインスタンスのセキュリティグループ ID。

sg-2vcgdxz7o1n9zapp****

BatchWindow

object

The batching window.

CountBasedWindow

integer

ウィンドウに含めることができるイベントの最大数。このしきい値に達すると、ウィンドウ内のデータがダウンストリームにプッシュされます。複数

100

TimeBasedWindow

integer

The maximum time range (in seconds) for events in the window. When this threshold is reached, the data in the window is pushed downstream. If multiple windows exist, data is pushed when any one window meets the threshold.

10

BusinessOption

object

BusinessMode

string

MinCapacityUnitCount

integer

MaxCapacityUnitCount

integer

Throttling

integer

Status

string

The status of the retrieved event stream.

RUNNING

DetailedStatus

object

The detailed status.

TPS

number

1 秒あたりのトランザクション数。

5

DelayTime

integer

The delay time.

3

DiffOffset

integer

The difference offset.

0

Extensions

object

The extension properties.

{ "test": "test", "test2": 1 }

Code

string

The response code. Success indicates a successful operation. Other values indicate error codes. For more information, see Error codes.

Success

Success

boolean

Returns true if the operation is successful.

true

エラーコード

HTTP ステータスコード

エラーコード

エラーメッセージ

説明

403 ServiceNotEnable Service not enable

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

変更履歴

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