UpdateEventStreaming でイベントストリームを更新 - EventBridge - Alibaba Cloud - EventBridge

イベントストリームの基本情報、イベントソース情報、イベントフィルタリングパターン、またはイベントターゲット情報を変更します。

操作説明

イベントストリームの基本情報、イベントソース情報、イベントフィルタリングパターン、またはイベントターゲット情報を変更します。

今すぐお試しください

この 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:UpdateEventStreaming

update

*EventStreaming

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

なし

リクエストパラメーター

パラメーター	型	必須 / 任意	説明	例
EventStreamingName	string	必須	イベントストリームの名前。	myeventstreaming
Description	string	任意	イベントストリームの説明。	rocketmq2mns
FilterPattern	string	任意	イベントフィルタリングパターン。このパラメーターを指定しない場合、すべてのイベントがマッチングされます。詳細については、https://www.alibabacloud.com/help/en/eventbridge/user-guide/event-patterns を参照してください。	{ "source": [ { "prefix": "acs:mns" } ], "type": [ { "prefix": "mns:Queue" } ], "subject": [ { "prefix": "acs:mns:cn-hangzhou:123456789098****:queues/zeus" } ] }
Source	object	任意	イベントプロバイダー。Source タイプを 1 つだけ選択する必要があります。
SourceMNSParameters	object	任意	ソース Simple メッセージキュー（旧 MNS）パラメーター。
RegionId	string	任意	リージョン ID。	cn-hangzhou
QueueName	string	任意	キュー名。	queue_api_1642474203601
IsBase64Decode	boolean	任意	Base64 デコードを有効にするかどうかを指定します。デフォルト値: true。	true
SourceRabbitMQParameters	object	任意	ソース RabbitMQ パラメーター。
RegionId	string	任意	リージョン ID。	cn-hangzhou
InstanceId	string	任意	ApsaraMQ for RabbitMQ インスタンスの ID。	i-f8z9lqkldlb4oxsxwwub
VirtualHostName	string	任意	ApsaraMQ for RabbitMQ インスタンスのバーチャルホスト名。	eb-connect
QueueName	string	任意	ApsaraMQ for RabbitMQ インスタンスのキュー名。	demo
SourceKafkaParameters	object	任意	ソース Kafka パラメーター。
RegionId	string	任意	リージョン ID。	cn-zhangjiakou
InstanceId	string	任意	インスタンス ID。	i-8vbh4a5b9yfhgkkzm****
Topic	string	任意	Topic 名。	topic_empower_1641539400786
ConsumerGroup	string	任意	Topic をサブスクライブする消費者のグループ ID。	DEFAULT_GROUP
OffsetReset	string	任意	オフセット。	latest
Network	string	任意	ネットワーク構成。デフォルト値: Default。VPC ネットワークの場合は PublicNetwork に設定します。	Default
VpcId	string	任意	VPC ID。	vpc-2ze6p0o345nykmekxt****
VSwitchIds	string	任意	vSwitch ID。	vsw-wz9t1l1e8eu2om****
SecurityGroupId	string	任意	セキュリティグループ ID。	sg-uf6jcm3y5hcs7hkl****
ValueDataType	string	任意	エンコードおよびデコードパラメーター。有効な値: a. Json: バイトが UTF-8 を使用して文字列にデコードされ、JSON として解析されます。 b. Text: バイトが UTF-8 を使用して文字列にデコードされ、ペイロードに直接配置されます。 c. Binary: バイトが Base64 エンコーディングを使用して文字列にエンコードされ、ペイロードに配置されます。	Text
SourceRocketMQParameters	object	任意	ソース RocketMQ パラメーター。
RegionId	string	任意	ApsaraMQ for RocketMQ インスタンスのリージョン ID。	cn-shanghai
InstanceId	string	任意	ApsaraMQ for RocketMQ インスタンスのインスタンス ID。	i-f8z9a9mcgwri1c1id****
Topic	string	任意	Topic 名。	TOPIC-cainiao-pcs-order-process-inBoundConditionCheck
Tag	string	任意	メッセージのフィルタータグ。	test
Offset	string	任意	メッセージの消費オフセット。有効な値: CONSUMEFROMLASTOFFSET: 最大オフセットから消費を開始します。 CONSUMEFROMFIRSTOFFSET: 最小オフセットから消費を開始します。 CONSUMEFROMTIMESTAMP: 指定した時間のポイントのオフセットから消費を開始します。デフォルト値: CONSUMEFROMLAST_OFFSET。	CONSUMEFROMLASTOFFSET
GroupID	string	任意	ApsaraMQ for RocketMQ インスタンスのグループ ID。	GID_test
Timestamp	integer	任意	タイムスタンプ。このパラメーターは、Offset パラメーターが CONSUMEFROMTIMESTAMP に設定されている場合にのみ有効です。	1670656652009
InstanceType	string	任意	インスタンスタイプ。有効な値: Cloud_4（デフォルト）: Alibaba Cloud RocketMQ 4.0 インスタンス。 Cloud_5: Alibaba Cloud RocketMQ 5.0 インスタンス。 SelfBuilt: セルフマネージド Apache RocketMQ インスタンス。	Cloud_5
InstanceEndpoint	string	任意	インスタンスエンドポイント。	reg****-vpc.cn-zhangjiakou.aliyuncs.com
InstanceUsername	string	任意	インスタンスのユーザー名。	admin
InstancePassword	string	任意	インスタンスのパスワード。	admin
AuthType	string	任意	認証タイプ。	ACL
InstanceVpcId	string	任意	インスタンスの VPC 情報。	vpc-m5e3sv4b12345****
InstanceVSwitchIds	string	任意	インスタンスの vSwitch 情報。	vsw-m5ev8asdc6h12****
InstanceSecurityGroupId	string	任意	インスタンスのセキュリティグループ情報。	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	任意	ApsaraMQ for RocketMQ インスタンスのタイプ。	Cloud_5
InstanceId	string	任意	ApsaraMQ for RocketMQ インスタンスのインスタンス ID。	rmq-cn-jte3w******
Topics	array	任意	ApsaraMQ for RocketMQ インスタンスの Topic。
	string	任意	ApsaraMQ for RocketMQ インスタンスの Topic。	myTopic
SourceApacheRocketMQCheckpointParameters	object	任意	ソース RocketMQ チェックポイントパラメーター。
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	任意	ネットワークタイプ。有効な値: PublicNetwork PrivateNetwork	PrivateNetwork
VpcId	string	任意	VPC ID。	vpc-adw1awdw*****
VSwitchId	string	任意	vSwitch ID。	vsw-dwaafds****
SecurityGroupId	string	任意	セキュリティグループ ID。	sg-mw43*****
SourceMQTTParameters	object	任意	ソース MQTT パラメーター。
RegionId	string	任意	リージョン ID。	cn-shanghai
InstanceId	string	任意	インスタンス ID。	i-bp1dsudbecqwt61j****
Topic	string	任意	Topic 名。	topic_empower_1642400400779
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。	f86e5814-b223-482c-b768-3b873297****
BrokerUrl	string	任意	データサブスクリプションチャンネルのネットワークアドレスとポート番号。
Topic	string	任意	データサブスクリプションチャンネルのサブスクリプション Topic。	LTC_CACHE_PRD
Sid	string	任意	コンシューマーグループ ID。	hkprdb
Username	string	任意	コンシューマーグループのアカウント。	admin
Password	string	任意	コンシューマーグループアカウントのパスワード。	admin
InitCheckPoint	integer	任意	消費チェックポイント。SDK クライアントが最初のデータ Record を消費するタイムスタンプの値です。値は UNIX タイムスタンプです。	1620962769
SourceSLSParameters	object	任意	ソース SLS パラメーター。
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	任意	ApsaraMQ for 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	任意
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 認証とは無関係です。
SslTruststoreCertificates	string	任意	[SSL に必須] Kafka サーバー信頼証明書。Kafka ブローカーの SSL 証明書を認証し、中間者攻撃を防止するために使用されます。フォーマット: PEM フォーマットの Base64 エンコーディング。通常、Kafka サーバーの CA 証明書またはサーバー証明書を含みます。例: CA 証明書の PEM ファイルコンテンツを Base64 エンコードします（'-----BEGIN CERTIFICATE-----' で始まり '-----END CERTIFICATE-----' で終わることを確認してください）。Kafka が自己署名証明書を使用している場合は、その証明書を発行した CA 証明書を指定します。
SslKeystoreKey	object	任意	[双方向認証に必須] SSL 秘密鍵構成オブジェクト。Kafka サーバーが双方向 SSL 認証を有効にしている場合にクライアント秘密鍵を指定します。KMS パターンのみサポートされます: KmsArn を使用してシークレットを格納する KMS EPS リソースを指定します。システムは KMS から秘密鍵コンテンツをメモリ内でのみ取得するため、より高いセキュリティを提供します。構成例: {"KmsArn": "acs:kms:ap-southeast-1:123456789:secret/ssl-key-xxxx", "KmsSecretValueKey": "keystore_private_key"}
KmsArn	string	任意	[必須] SSL 秘密鍵を格納する KMS リソース Amazon リソースネーム (ARN)。クライアント秘密鍵を格納するキー管理サービスインスタンスを特定するために使用されます。フォーマット例: 'acs:kms:ap-southeast-1:123456789:secret/ssl-keystore-key-xxxx'。KMS コンソールの対応するキーの Amazon リソースネーム (ARN) 情報からこの値を取得してください。
KmsSecretValueKey	string	任意	[KMS KV モード] KMS 認証情報内のキー名。KMS 認証情報がキーバリュー（KV）構造で格納されている場合、このパラメーターを指定して SSL 秘密鍵に対応するキーを示します。例: KMS 認証情報が '{"ssl_keystore_key":"-----BEGIN PRIVATE KEY-----...","ssl_truststore_key":"..."}' の場合、'ssl_keystore_key' を入力します。KMS 認証情報がプレーンテキストモード（秘密鍵の PEM コンテンツを直接格納）の場合、このパラメーターは空のままにしてください。
Topic	string	任意
ConsumerGroup	string	任意
OffsetReset	string	任意
ValueDataType	string	任意
VpcId	string	任意
VSwitchIds	string	任意
SecurityGroupId	string	任意
NetworkType	string	任意
SecurityProtocol	string	任意
SaslMechanism	string	任意
SaslUser	string	任意
SaslPassword	string	任意
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 です。	\n
SourceEventBusParameters	object	任意	ソース EventBus パラメーター。
EventBusName	string	任意	イベントバス名。	my-event-bus
EventRuleName	string	任意	イベントルール名。	my-event-rule
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	任意	ネットワークタイプ。有効な値: PublicNetwork PrivateNetwork	PrivateNetwork
AuthType	string	任意	認証タイプ。	ACL
SourceMySQLParameters	SourceMySQLParameters	任意	ソース MySQL パラメーター。
SourcePostgreSQLParameters	SourcePostgreSQLParameters	任意
SourceRabbitMQMetaParameters	SourceRabbitMQMetaParameters	任意
SourceRabbitMQMsgSyncParameters	SourceRabbitMQMsgSyncParameters	任意
SourceFeiShuDocsParameters	SourceFeiShuDocsParameters	任意
Metadata	string	任意
Sink	object	任意	イベントターゲット。Sink タイプを 1 つだけ選択する必要があります。
SinkMNSParameters	object	任意	Simple メッセージキュー（旧 MNS）イベントターゲット。
QueueName	object	任意	ターゲットサービスタイプは Simple メッセージキュー（旧 MNS）です。
Value	string	任意	Simple メッセージキュー（旧 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	任意	カタログ名。	demo
NamespaceName	string	任意	送信先テーブルの名前空間。	name1
EventTableName	string	任意	送信先テーブルの名前。	demo-table
MappingRules	array<object>	任意	フィールドマッピングルール。
	array<object>	任意	フィールドマッピングルール。
ColumnValue	object	任意	カラム値抽出ルール。
Value	string	任意	抽出パス（例: $.data.value.name）。	$.data.value
Form	string	任意	The transformation method, such as JSONPATH.	JSONPATH
Template	string	任意	テンプレート構成。	The value of ${key} is ${value}!
ColumnName	string	任意	カラム名。	age
ColumnType	string	任意	カラムタイプ。	text
SinkFcParameters	object	任意	関数ターゲット。
ServiceName	object	任意	サービス名。
Value	string	任意	サービス名。	myService
Form	string	任意	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	任意	なし。
FunctionName	object	任意	関数名。
Value	string	任意	関数名。	mFunction
Form	string	任意	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	任意	なし。
Concurrency	object	任意	配信の同時実行数。最小値: 1。
Value	string	任意	配信の同時実行数。最小値: 1。	1
Form	string	任意	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	任意	なし。
Qualifier	object	任意	関数が属するサービスのエイリアス。
Value	string	任意	関数が属するサービスのエイリアス。	LATEST
Form	string	任意	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	任意	なし。
InvocationType	object	任意	呼び出しタイプ。有効な値: Sync: 同期。 Async: 非同期。
Value	string	任意	呼び出しタイプ。	Async
Form	string	任意	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	任意	なし。
Body	object	任意	関数に送信されるコンテンツ本文。
Value	string	任意	The value before transformation.	{ "key": "value" }
Form	string	任意	The transformation format.	TEMPLATE
Template	string	任意	テンプレートスタイル。	The value of ${key} is ${value}!
DataFormat	object	任意	The format transformation rule for event content.
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	JSONPATH
Template	string	任意	テンプレートスタイル。	$.data.key
SinkRabbitMQParameters	object	任意	The Sink RabbitMQ parameters.
InstanceId	object	任意	The event target type is MSMQ for RabbitMQ.
Value	string	任意	The instance ID of ApsaraMQ for RabbitMQ.	amqp-cn-2r42e73o****
Form	string	任意	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	任意	なし。
VirtualHostName	object	任意	The vhost name of the MSMQ for RabbitMQ instance.
Value	string	任意	The vhost name of the ApsaraMQ for RabbitMQ instance.	rabbit-host
Form	string	任意	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	任意	なし。
TargetType	object	任意	The target type.
Value	string	任意	The target type. Valid values: Exchange: Exchange mode. Queue: Queue mode.	Exchange/Queue
Form	string	任意	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	任意	なし。
Exchange	object	任意	The Exchange mode. This parameter is required only when the TargetType parameter is set to Exchange.
Value	string	任意	The exchange name of the ApsaraMQ for RabbitMQ instance.	a_exchange
Form	string	任意	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	任意	なし。
RoutingKey	object	任意	The routing rule of the message. This parameter is required only when the TargetType parameter is set to Exchange.
Value	string	任意	The routing rule of the message.	housekeeping
Form	string	任意	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	任意	なし。
QueueName	object	任意	The Queue mode. This parameter is required only when the TargetType parameter is set to Queue.
Value	string	任意	The name of the queue of the instance.	MyQueue
Form	string	任意	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	任意	なし。
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	任意	The message 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}!
SinkKafkaParameters	object	任意	The Sink Kafka parameters.
InstanceId	object	任意	The event target type is MSMQ for Apache Kafka.
Value	string	任意	インスタンス ID。	Defaut_1283278472_s****
Form	string	任意	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	任意	なし。
CompressionType	string	任意
Topic	object	任意	Topic 名。
Value	string	任意	Topic 名。	test
Form	string	任意	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	任意	なし。
DynamicTopic	object	任意	Specifies the destination 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 (such as "order_created"). All messages are sent to this topic. 2. Dynamic extraction mode: Specify a standard JSONPath expression (such as "$.user.id" or "$.metadata.category"). The system parses the upstream message body and
Value	string	任意	The value.
Form	string	任意	The transform type. Valid values: CONSTANT: constant value. JSONPATH: extract from upstream based on a JSONPath expression.
Template	string	任意	The template.
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}!
Acks	object	任意	The acknowledgment mode for writing to Kafka: acks=0: No response is required from the server. This mode delivers higher performance but carries a greater risk of data loss. acks=1: A response is returned after the primary node writes successfully. This mode delivers moderate performance with a moderate risk of data loss. Data loss may occur if the primary node goes down. acks=all: A response is returned only after the primary node writes successfully and the secondary nodes complete synchronization. This mode delivers lower performance but provides greater data safety. Data loss occurs only if both the primary and secondary nodes go down.
Value	string	任意	The acknowledgment mode for writing to Kafka: acks=0: No response is required from the server. This mode delivers higher performance but carries a higher risk of data loss. acks=1: A response is returned after the primary node writes successfully. This mode delivers moderate performance with a moderate risk of data loss. Data loss may occur if the primary node goes down. acks=all: A response is returned only after the primary node writes successfully and the secondary nodes complete synchronization. This mode delivers lower performance but provides stronger data safety. Data loss occurs only if both the primary and secondary nodes go down.	1
Form	string	任意	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	任意	なし。
Key	object	任意	The identifier of the message.
Value	string	任意	The identifier of the message.	key
Form	string	任意	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	任意	なし。
Value	object	任意	The message body content.
Value	string	任意	The value before transformation.	{ "key": "value" }
Form	string	任意	The transformation format.	TEMPLATE
Template	string	任意	テンプレートスタイル。	The value of ${key} is ${value}!
SinkApacheKafkaParameters	object	任意	The description.
Bootstraps	string	任意
Topic	string	任意
DynamicTopic	object	任意	Specifies the destination 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 (such as "order_created"). All messages are sent to this topic. 2. Dynamic extraction mode: Specify a standard JSONPath expression (such as "$.user.id" or "$.metadata.category"). The system parses the upstream message body and
Value	string	任意	The value.
Form	string	任意	The transform type. Valid values: CONSTANT: constant value. JSONPATH: extract from upstream based on a JSONPath expression.
Template	string	任意	The template.
Acks	string	任意
Key	object	任意
Value	string	任意
Form	string	任意
Template	string	任意
Value	object	任意
Value	string	任意
Form	string	任意
Template	string	任意
CompressionType	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	任意
Headers	object	任意
Value	string	任意
Form	string	任意
Template	string	任意
SaslPassword	string	任意
SslKeystoreCertificateChain	string	任意	[Required for mutual authentication] Kafka client certificate chain. Provide this parameter 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, followed by intermediate CA certificates, with the root CA certificate being optional). Ensure that each PEM file starts with '-----BEGIN CERTIFICATE-----' and ends with '-----END CERTIFICATE-----', then Base64-encode the concatenated content.
SslKeyPassword	string	任意	[Required for encrypted private keys] Kafka client private key password. Provide the decryption password when the client private key is encrypted (the PEM file contains 'Proc-Type: 4,ENCRYPTED' or 'ENCRYPTED' markers). Leave this parameter empty if the private key is not encrypted. This password is used only to decrypt the private key and is unrelated to Kafka authentication.
SslTruststoreCertificates	string	任意	[Required for SSL] The Kafka server trust certificate. Used to authenticate the legitimacy of the Kafka Broker SSL certificate and prevent man-in-the-middle attacks. Format: Base64 encoding of PEM format, typically containing the CA certificate or the server certificate of the Kafka server. Example: Base64-encode the PEM file content of the CA certificate (ensure it begins with '-----BEGIN CERTIFICATE-----' and ends with '-----END CERTIFICATE-----'). If Kafka uses a self-signed certificate, provide the CA certificate that issued it.
SslKeystoreKey	object	任意	[Required for bidirectional authentication] The SSL private key configuration object. When the Kafka server enables bidirectional SSL authentication, a client private key is required. Only KMS pattern is supported for the key: specify the Key Management Service EPS resource that stores the private key through KmsArn. The system retrieves the private key content from KMS only in memory, providing higher security. Configuration example: {"KmsArn": "acs:kms:ap-southeast-1:123456789:secret/ssl-key-xxxx", "KmsSecretValueKey": "keystore_private_key"}\n"
KmsArn	string	任意	[Required] The KMS resource ARN that stores the SSL private key. Used to locate the Key Management Service instance that stores the client private key. Format example: 'acs:kms:ap-southeast-1:123456789:secret/ssl-keystore-key-xxxx'. Obtain this value from the ARN information of the corresponding key in the KMS console.
KmsSecretValueKey	string	任意	[KMS KV mode] The key name in the KMS credential. When the KMS credential is stored as a key-value (KV) structure, specify this parameter to indicate the key corresponding to the SSL private key. Example: if the KMS credential is '{"ssl_keystore_key":"-----BEGIN PRIVATE KEY-----...","ssl_truststore_key":"..."}', enter 'ssl_keystore_key'. Leave this parameter empty if the KMS credential is in plain text mode (directly storing the PEM content of the private key).
SinkRocketMQParameters	object	任意	Sink RocketMQ Parameters
InstanceId	object	任意	The event target type is MSMQ for RocketMQ.
Value	string	任意	The instance ID of ApsaraMQ for RocketMQ.	MQ_INST_164901546557**_BAAN**
Form	string	任意	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	任意	なし。
Topic	object	任意	The topic of the MSMQ for RocketMQ instance.
Value	string	任意	ApsaraMQ for RocketMQ インスタンスの Topic。	Mytopic
Form	string	任意	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	任意	なし。
Body	object	任意	メッセージ本文。
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}!
Keys	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}!
Tags	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}!
InstanceType	object	任意	The instance type.
Value	string	任意	The instance type. Valid values: Cloud_4: Alibaba Cloud RocketMQ 4.0 instance (default) Cloud_5: Alibaba Cloud RocketMQ 5.0 instance SelfBuilt: self-managed Apache RocketMQ cluster	Cloud_4
Form	string	任意	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	任意	なし。
InstanceEndpoint	object	任意	インスタンスエンドポイント。
Value	string	任意	インスタンスエンドポイント。	vbr-8vbsvkkbpf3vb0zef****
Form	string	任意	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	任意	なし。
InstanceUsername	object	任意	インスタンスのユーザー名。
Value	string	任意	インスタンスのユーザー名。	admin
Form	string	任意	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	任意	なし。
InstancePassword	object	任意	インスタンスのパスワード。
Value	string	任意	インスタンスのパスワード。	admin****
Form	string	任意	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	任意	なし。
VpcId	object	任意	VPC ID。
Value	string	任意	The VPC ID.	vbr-8vb835n3zf9shwlvb****
Form	string	任意	The event transformation format. Default value: CONSTANT.	CONSTANT
Template	string	任意	なし。
VSwitchIds	object	任意	vSwitch ID。
Value	string	任意	vSwitch ID。	vbr-8vb835n3zf9shwl****mp
Form	string	任意	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	任意	なし。
SecurityGroupId	object	任意	セキュリティグループ ID。
Value	string	任意	セキュリティグループ ID。	b4bf375515f6440f942e3a20c33d****
Form	string	任意	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	任意	なし。
Network	object	任意	ネットワークタイプ。有効な値: 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. Defaults to concurrent delivery.
Value	string	任意	The delivery order type. Valid values: Orderly: ordered delivery. Concurrently: concurrent delivery.	Concurrently
Form	string	任意	The transform format. Default value: CONSTANT.	CONSTANT
Template	string	任意	テンプレートスタイル。
ShardingKey	object	任意	The sharding key of the message. 説明 When DeliveryOrderType is set to Orderly, this specifies the event content transformation rule for the ShardingKey property when writing messages downstream. When the source is RocketMQ, ShardingKey can be empty. In this case, the message ShardingKey is generated by concatenating the upstream BrokerName and QueueId.
Value	string	任意	The sharding key value.	order_id
Form	string	任意	The transform format. Default value: CONSTANT.	CONSTANT
Template	string	任意	テンプレートスタイル。
SinkDorisParameters	object	任意	The event source type.
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	任意
Body	object	任意
Value	string	任意
Form	string	任意
Template	string	任意
Table	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 Parameters
InstanceType	string	任意	The instance type. Valid values: Cloud_4: Alibaba Cloud RocketMQ 4.0 instance Cloud_5: Alibaba Cloud RocketMQ 5.0 instance	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 ApsaraMQ for RocketMQ instance.	Mytopic
Form	string	任意	The transform format. Default value: CONSTANT.	CONSTANT
Template	string	任意	テンプレートスタイル。
ConsumeTimestamp	object	任意	The timestamp of message consumption.
Value	string	任意	The timestamp.	1570761026400
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	任意	テンプレートスタイル。
SinkApacheRocketMQCheckpointParameters	object	任意	Sink Apache RocketMQ Checkpoint Parameters
Topic	object	任意	The topic of the RocketMQ instance.
Value	string	任意	The topic name of the RocketMQ instance.	Mytopic
Form	string	任意	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	任意	テンプレートスタイル。
ConsumeTimestamp	object	任意	The timestamp of message consumption.
Value	string	任意	The timestamp.	1570761026400
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	任意	テンプレートスタイル。
InstanceEndpoint	string	任意	インスタンスエンドポイント。	192.168.1.1:9876
InstanceUsername	string	任意	The username required for authentication.	admin
InstancePassword	string	任意	The password for the username.	****
NetworkType	string	任意	ネットワークタイプ。有効な値: PublicNetwork PrivateNetwork	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	任意	The project of Simple Log Service.
Value	string	任意	The project of Simple Log Service.	test-project
Form	string	任意	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	任意	なし。
LogStore	object	任意	The Logstore of Simple Log Service.
Value	string	任意	The Logstore of Simple Log Service.	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	任意	The role that provides authorization for the event bus EventBridge to read Simple Log Service log content. When creating the role in the Resource Access Management (RAM) console, select "Alibaba Cloud Service" and set "Trusted Service" to "event bus".
Value	string	任意	The role that provides authorization for the event bus EventBridge to read Simple Log Service log content. When creating the role in the Resource Access Management (RAM) console, select "Alibaba Cloud Service" and set "Trusted Service" to "event bus".	testRole
Form	string	任意	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	任意	なし。
ContentType	object	任意	The data format of Simple Log Service. You can select the default format or configure specified key-value pairs. Valid values: JSON KeyValue
Value	string	任意	The data format of Simple Log Service.	JSON
Form	string	任意	The transformation format.	CONSTANT
Template	string	任意	テンプレートスタイル。
ContentSchema	object	任意	The custom log key-value pairs. This parameter takes effect only when ContentType is set to KeyValue. Each key-value pair is represented by Key_n and Value_n.
Value	string	任意	The custom key-value pairs.	{"Key_1":{"form":"CONSTANT","value":"demoKey"},"Value_1":{"form":"JSONPATH","value":"$.data.value"}}
Form	string	任意	The transformation format.	CONSTANT
Template	string	任意	テンプレートスタイル。
SinkFnfParameters	object	任意	The Sink Fnf parameters.
FlowName	object	任意	The flow name.
Value	string	任意	The flow name.	test-streaming-fnf
Form	string	任意	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	任意	テンプレートスタイル。
ExecutionName	object	任意	The execution name.
Value	string	任意	The execution name.	123
Form	string	任意	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	任意	テンプレートスタイル。
Input	object	任意	The execution input information.
Value	string	任意	The execution input information.	123
Form	string	任意	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	任意	テンプレートスタイル。
RoleName	object	任意	The role configuration.
Value	string	任意	The role configuration.	Al**FNF-x**
Form	string	任意	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	任意	テンプレートスタイル。
SinkPrometheusParameters	object	任意	The Sink Prometheus parameters.
URL	object	任意	The Prometheus Remote Write URL.
Value	string	任意	The Prometheus Remote Write URL.	https://cn-hangzhou.arms.aliyuncs.com/prometheus/167275**/c5b7faeb2e8994641***d5c559f/cn-hangzhou/api/v3/write
Form	string	任意	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	任意	なし。
HeaderParameters	object	任意	The data structure of request header parameters.
Value	string	任意	If Form is CONSTANT: a constant value. If Form is JSONPATH: content extracted by using a JSONPath expression. If Form is TEMPLATE: a template variable. Note: The Value field cannot exceed 10,240 characters.	name
Form	string	任意	The transform format. Valid values: JSONPATH CONSTANT TEMPLATE	TEMPLATE
Template	string	任意	The HTTP request header template. Specify this parameter when Form is set to TEMPLATE. The result after event content transformation must be in JSON format.	{ "user_name":"${name}" }
AuthorizationType	object	任意	認証タイプ。
Value	string	任意	認証タイプ。	BASIC_AUTH
Form	string	任意	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	任意	なし。
Username	object	任意	The username.
Value	string	任意	The username.	***admin
Form	string	任意	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	任意	なし。
Password	object	任意	The password.
Value	string	任意	The password.	abc
Form	string	任意	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	任意	なし。
Data	object	任意	The metric content.
Value	string	任意	The metric content.	$.data
Form	string	任意	The transform format. Default value: JSONPATH.	JSONPATH
Template	string	任意	なし。
NetworkType	object	任意	ネットワークタイプ。
Value	string	任意	ネットワークタイプ。有効な値: PublicNetwork PrivateNetwork	PrivateNetwork
Form	string	任意	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	任意	なし。
VpcId	object	任意	VPC ID。
Value	string	任意	VPC ID。	vpc-adw1awdw*****
Form	string	任意	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	任意	なし。
VSwitchId	object	任意	vSwitch ID。
Value	string	任意	vSwitch ID。	vsw-dwaafds****
Form	string	任意	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	任意	なし。
SecurityGroupId	object	任意	セキュリティグループ ID。
Value	string	任意	セキュリティグループ ID。	sg-mw43*****
Form	string	任意	The transformation format. Default value: 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	任意	なし。
Topic	object	任意	The DataHub topic name.
Value	string	任意	The DataHub topic name.	demo-topic
Form	string	任意	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	任意	なし。
TopicType	object	任意	The topic type. Valid values: TUPLE BLOB
Value	string	任意	The topic type. Valid values: TUPLE BLOB	TUPLE
Form	string	任意	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	任意	なし。
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	任意	The transformation format.	TEMPLATE
Template	string	任意	テンプレートスタイル。	{"k1":"${k1}","k2":"${k2}"}
Body	object	任意	The record content template for the BLOB type.
Value	string	任意	The record content template for the BLOB type.
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	任意	なし。
ContentType	object	任意	The data format. You can select the default format or configure specified key-value pairs. Valid values: JSON KeyValue
Value	string	任意	The value before transformation.	JSON
Form	string	任意	The transformation format.	CONSTANT
Template	string	任意	テンプレートスタイル。
ContentSchema	object	任意	The custom log key-value pairs. This parameter takes effect only when ContentType is set to KeyValue. Each key-value pair is represented by Key_n and Value_n.
Value	string	任意	The value before transformation.	{"Key_1":{"form":"CONSTANT","value":"demoKey"},"Value_1":{"form":"JSONPATH","value":"$.data.value"}}
Form	string	任意	テンプレートスタイル。	CONSTANT
Template	string	任意	テンプレートスタイル。
SinkCustomizedKafkaParameters	object	任意	The Sink Kafka parameters.
InstanceId	string	任意	The instance ID of MSMQ for Apache Kafka.	90be1f96-4229-4535-bb76-34b4f6fb2b71
SinkCustomizedKafkaConnectorParameters	object	任意	The Sink Kafka connector parameters.
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=rb8q3OpV2i3gZJ"
ConnectorParameters	object	任意	Parses the properties file in the current ZIP package.
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	任意	The Sink DashVector parameters.
InstanceId	string	任意	インスタンス ID。	vrs-cn-lbj3ru1***
Collection	string	任意	The collection name.	collection1
ApiKey	string	任意	The API key created in the DashVector console.	Q34nExQH7sQ****
Operation	string	任意	The DashVector database operation type. Valid values: Delete Upsert	Upsert
Network	string	任意	The network type. Valid values: PrivateNetwork PublicNetwork	PublicNetwork
PrimaryKeyId	object	任意	The primary key ID for inserting or deleting records. If this field is not specified, a random primary key ID is used.
Form	string	任意	The transform format. Valid values: JSONPATH TEMPLATE	JSONPATH
Value	string	任意	If Form is JSONPATH: content extracted by using a JSONPath expression. If Form is TEMPLATE: a template variable. 説明 The Value field cannot exceed 10,240 characters.	$.data.requestId
Template	string	任意	The primary key ID template. Specify this parameter only when Form is set to TEMPLATE.	${ID}
Partition	object	任意	The partition. Default value: default.
Form	string	任意	The transform format. Valid values: JSONPATH CONSTANT	CONSTANT
Value	string	任意	If Form is CONSTANT: a constant value. If Form is JSONPATH: content extracted by using a JSONPath expression. 説明 The Value field cannot exceed 10,240 characters.	default
Template	string	任意	なし。
Vector	object	任意	The vector for the record to be inserted into DashVector.
Form	string	任意	The transformation format.	JSONPATH
Value	string	任意	The content extracted by using a JSONPath expression. 説明 The Value field cannot exceed 10,240 characters.	$.data.messageBody
Template	string	任意	なし。
DashVectorSchemaParameters	array<object>	任意	The schema field definition for table entries when inserting into DashVector. The result after 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	任意	The target type for message delivery. Valid values: Exchange: Messages are routed through an exchange. Queue: Messages are delivered directly to a specified queue.	Exchange
Exchange	string	任意	The exchange name in RabbitMQ. This parameter takes effect when TargetType is set to Exchange.	my-exchange
QueueName	string	任意	The queue name in RabbitMQ. This parameter takes effect only when TargetType is set to Queue.	my-queue
Username	string	任意	The username for accessing the RabbitMQ instance.	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	任意	The network type. Valid values: PrivateNetwork PublicNetwork	PublicNetwork
AuthType	string	任意	The authentication type. Valid values: ACL No configuration required	ACL
RoutingKey	object	任意	The message routing key.
Form	string	任意	The transform format. Default value: CONSTANT.	CONSTANT
Value	string	任意	The routing key value.	{"Form": "CONSTANT", "Value": "my-routing-key"}
Template	string	任意	テンプレートスタイル。	The value of ${key} is ${value}!
Body	object	任意	The message body content.
Form	string	任意	The transform format. Default value: CONSTANT.	CONSTANT
Value	string	任意	The raw data value.	{"key": "value"}
Template	string	任意	テンプレートスタイル。	The value of ${key} is ${value}!
MessageId	object	任意	The unique identifier of the message.
Form	string	任意	The transform format. Default value: CONSTANT.	CONSTANT
Value	string	任意	The message ID value.	12345
Template	string	任意	テンプレートスタイル。
Properties	object	任意	The additional properties of the message.
Form	string	任意	The transform 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	任意	The HTTPS target parameters.
SinkApiDestinationParameters	SinkApiDestinationParameters	任意	The ApiDestination target parameters.
SinkOSSParameters	SinkOSSParameters	任意
SinkRabbitMQMetaParameters	SinkRabbitMQMetaParameters	任意
SinkRabbitMQMsgSyncParameters	SinkRabbitMQMsgSyncParameters	任意
SinkMQTTParameters	SinkMQTTParameters	任意
SinkAgentRunParameters	SinkAgentRunParameters	任意
RunOptions	object	任意	The runtime environment parameters.
MaximumTasks	integer	任意	The concurrency.	2
ErrorsTolerance	string	任意	The error tolerance policy: NONE (no error tolerance) or ALL (tolerate all errors).	ALL
RetryStrategy	object	任意	The retry policy when event push fails.
PushRetryStrategy	string	任意	The retry policy: BACKOFF_RETRY (backoff retry) or EXPONENTIAL_DECAY_RETRY (exponential decay retry).	BACKOFF_RETRY
MaximumEventAgeInSeconds	integer	任意	The maximum retry time.	512
MaximumRetryAttempts	integer	任意	The maximum number of retry attempts.	2
DeadLetterQueue	object	任意	Specifies whether to enable the dead-letter queue. The dead-letter queue is disabled by default. Messages that exceed the retry policy are discarded.
Arn	string	任意	The ARN of the dead-letter queue.	acs:ram::131733464781****:role/rdstoecsassumekms
Network	string	任意	The network type of the dead-letter queue. Valid values: PrivateNetwork PublicNetwork	PrivateNetwork
VpcId	string	任意	The VPC ID where the dead-letter queue resides.	vpc-2zehizpoendb3****
VSwitchIds	string	任意	The vSwitch ID where the dead-letter queue resides.	vsw-m5ev8asdc6h12345****
SecurityGroupId	string	任意	The security group ID of the instance where the dead-letter queue resides.	sg-2vcgdxz7o1n9zapp****
BatchWindow	object	任意	The batch window.
CountBasedWindow	integer	任意	The maximum number of events that the window can contain. When this threshold is reached, the data in the window is pushed downstream. If multiple windows exist, a push is triggered when any window meets the threshold.	100
TimeBasedWindow	integer	任意	The maximum time range (in seconds) of events that the window can contain. When this threshold is reached, the data in the window is pushed downstream. If multiple windows exist, a push is triggered when any window meets the threshold.	10
BusinessOption	object	任意
BusinessMode	string	任意
MinCapacityUnitCount	integer	任意
MaxCapacityUnitCount	integer	任意
Throttling	integer	任意
Transforms	array<object>	任意	The Transform-related configurations.
	object	任意	The ARN of the cloud service resource, such as the ARN of a function in Function Compute.
Arn	string	任意	The ARN of the cloud service resource, such as the ARN of a function in Function Compute.	acs:fc:cn-hangzhou:*****:services/demo-service.LATEST/functions/demo-func
DashScopeTransformParameters	DashScopeTransformParameters	任意
BaiLianAgentTransformParameters	BaiLianAgentTransformParameters	任意

レスポンスフィールド

フィールド	型	説明	例
	object	The response parameters.
Message	string	The error message.	The name [xxxx] of event streaming in request is already exist!
RequestId	string	The request ID generated by Alibaba Cloud for this request.	0FDD73AA-7A2D-5BD4-B4C0-88AFEBF5F0F5
Code	string	The response code. Valid values: Success: The request was successful. Other values indicate error codes. For more information, see Error codes.	Success
Success	boolean	Returns true if the operation is successful.	true

例

成功レスポンス

JSONJSON

{
  "Message": "The name [xxxx] of event streaming in request is already exist!",
  "RequestId": "0FDD73AA-7A2D-5BD4-B4C0-88AFEBF5F0F5",
  "Code": "Success",
  "Success": true
}

エラーコード

HTTP ステータスコード	エラーコード	エラーメッセージ	説明
403	ServiceNotEnable	Service not enable

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

変更履歴

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