CreateEventStreaming でイベントストリームを作成 - 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:CreateEventStreaming

create

*EventStreaming

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

なし

リクエストパラメーター

パラメーター	型	必須 / 任意	説明	例
EventStreamingName	string	必須	イベントストリームの名前。	myeventstreaming
Description	string	任意	イベントストリームの説明。	rocketmq2mns
FilterPattern	string	任意	イベントフィルタールール。このパラメーターを指定しない場合、すべてのイベントが一致します。	{ "source": [ { "prefix": "acs:mns" } ], "type": [ { "prefix": "mns:Queue" } ], "subject": [ { "prefix": "acs:mns:cn-hangzhou:123456789098****:queues/zeus" } ] }
Source	object	任意	イベントプロバイダー。ソースタイプを 1 つだけ指定する必要があります。
SourceMNSParameters	object	任意	MNS ソースのパラメーター。
RegionId	string	任意	リージョン ID。	cn-beijing
QueueName	string	任意	キュー名。	queue_api_1642474203601
IsBase64Decode	boolean	任意	Base64 デコードを有効にするかどうかを指定します。デフォルト値: true。	true
SourceRabbitMQParameters	object	任意	RabbitMQ ソースのパラメーター。
RegionId	string	任意	リージョン ID。	cn-hangzhou
InstanceId	string	任意	ApsaraMQ for RabbitMQ インスタンスのインスタンス ID。	gtm-cn-k2c2yfg****
VirtualHostName	string	任意	ApsaraMQ for RabbitMQ インスタンスの vhost 名。	eb-connect
QueueName	string	任意	ApsaraMQ for RabbitMQ インスタンスのキュー名。	demo
SourceKafkaParameters	object	任意	Kafka ソースのパラメーター。
RegionId	string	任意	リージョン ID。	cn-hangzhou
InstanceId	string	任意	インスタンス ID。	r-8vb64581862c****
Topic	string	任意	Topic 名。	popvip_center_robot_order
ConsumerGroup	string	任意	Topic をサブスクライブする消費者のグループ ID。	DEFAULT_GROUP
OffsetReset	string	任意	オフセット。	latest
Network	string	任意	ネットワーク構成。デフォルト値: Default。VPC ネットワークの場合、このパラメーターを PublicNetwork に設定します。	Default
VpcId	string	任意	VPC ID。	vpc-8vblalsi0vbhizr77****
VSwitchIds	string	任意	vSwitch ID。	vsw-bp179l3llg3jjxwrq72****
SecurityGroupId	string	任意	セキュリティグループ ID。	sg-bp1iv19sp1msc7zot4****
ValueDataType	string	任意	メッセージ本文のエンコード形式およびデコードフォーム。有効な値: JSON Text Binary	JSON
SourceRocketMQParameters	object	任意	RocketMQ ソースのパラメーター。
RegionId	string	任意	リージョン ID。	cn-qingdao
InstanceId	string	任意	ApsaraMQ for RocketMQ インスタンスが存在するリージョン。	default_C56C36026****
Topic	string	任意	メッセージングサービスの Topic。	Topic_publicRule_api_1667273421288
Tag	string	任意	メッセージのフィルタータグ。	test
Offset	string	任意	メッセージの消費オフセット。有効な値: CONSUME_FROM_LAST_OFFSET: 最大オフセットから消費を開始します。 CONSUME_FROM_FIRST_OFFSET: 最小オフセットから消費を開始します。 CONSUME_FROM_TIMESTAMP: 指定した時間のポイントのオフセットから消費を開始します。デフォルト値: CONSUME_FROM_LAST_OFFSET。	CONSUMEFROMLAST_OFFSET
GroupID	string	任意	ApsaraMQ for RocketMQ インスタンスのグループ ID。	GID_group1
Timestamp	integer	任意	タイムスタンプ。このパラメーターは、Offset パラメーターが CONSUME_FROM_TIMESTAMP に設定されている場合にのみ有効です。	1670656652009
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
InstanceUsername	string	任意	インスタンスのユーザー名。	admin
InstancePassword	string	任意	インスタンスのパスワード。	admin
Network	string	任意	ネットワークタイプ。有効な値: PublicNetwork PrivateNetwork 列挙値: PrivateNetwork : PrivateNetwork。 PublicNetwork : PublicNetwork。	PrivateNetwork
FilterType	string	任意	メッセージフィルタータイプ。	Tag
FilterSql	string	任意	SQL フィルター文。	index > 10
AuthType	string	任意	認証タイプ。	ACL
VpcId	string	任意	クロスボーダータスクの VPC ID。	vpc-m5e3sv4b12345****
VSwitchIds	string	任意	クロスボーダータスクの vSwitch ID。	vsw-m5ev8asdc6h12345****
SecurityGroupId	string	任意	クロスボーダータスクのセキュリティグループ。	sg-m5edtu24f12345****
InstanceVpcId	string	任意	インスタンスの VPC 情報。	vpc-m5e3sv4b12345****
InstanceVSwitchIds	string	任意	インスタンスの vSwitch 情報。	vsw-m5ev8asdc6h123456****
InstanceSecurityGroupId	string	任意	インスタンスのセキュリティグループ情報。	sg-m5edtu24f12345****
InstanceNetwork	string	任意	インスタンスのネットワーク情報。有効な値: PublicNetwork PrivateNetwork	PublicNetwork
BodyDataType	string	任意	メッセージのエンコード形式。有効な値: JSON Text Binary	JSON
SourceRocketMQCheckpointParameters	object	任意	RocketMQ チェックポイントソースのパラメーター。
RegionId	string	任意	リージョン ID。
InstanceType	string	任意	インスタンスタイプ。
InstanceId	string	任意	インスタンス ID。
Topics	array	任意	メッセージ Topic。
	string	任意	メッセージ Topic。
SourceApacheRocketMQCheckpointParameters	object	任意	RocketMQ チェックポイントソースのパラメーター。
RegionId	string	任意	リージョン ID。
Topics	array	任意	メッセージ Topic。
	string	任意	メッセージ Topic。
InstanceEndpoint	string	任意	インスタンスエンドポイント。
InstanceUsername	string	任意	インスタンスのユーザー名。
InstancePassword	string	任意	インスタンスのパスワード。
NetworkType	string	任意	ネットワークタイプ。
VpcId	string	任意	VPC ID。
VSwitchId	string	任意	vSwitch ID。
SecurityGroupId	string	任意	セキュリティグループ ID。
SourceMQTTParameters	object	任意	MQTT ソースのパラメーター。
RegionId	string	任意	リージョン ID。	cn-shenzhen
InstanceId	string	任意	インスタンス ID。	r-bp1b5ncun5lqer****
Topic	string	任意	メッセージの Topic。	CANAL_VICUTU_UAT
BodyDataType	string	任意	メッセージのエンコード形式。有効な値: JSON Text Binary	JSON
NetworkType	string	任意
VpcId	string	任意
VSwitchIds	string	任意
SecurityGroupId	string	任意
SourceDTSParameters	object	任意	DTS ソースのパラメーター。
TaskId	string	任意	タスク ID。	f86e5814-b223-482c-b768-3b873297****
BrokerUrl	string	任意	データサブスクリプションチャンネルのネットワークアドレスとポート番号。
Topic	string	任意	データサブスクリプションチャンネルのサブスクリプション Topic。	LTC_CACHE_PRD
Sid	string	任意	コンシューマーグループ ID。	HD3
Username	string	任意	コンシューマーグループのアカウント。	admin
Password	string	任意	コンシューマーグループアカウントのパスワード。	admin
InitCheckPoint	integer	任意	消費オフセット。SDK クライアントが最初のデータ Record を消費する時間のタイムスタンプです。値は UNIX タイムスタンプです。	1620962769
SourceSLSParameters	object	任意	Simple Log Service (SLS) ソースのパラメーター。
Project	string	任意	Simple Log Service のプロジェクト。	test
LogStore	string	任意	Simple Log Service の Logstore。	sas-log
ConsumePosition	string	任意	初期消費オフセット。最小オフセットまたは最大オフセットを選択できます。それぞれ「begin」と「end」に対応します。秒単位で指定した時間から消費を開始することもできます。	end
RoleName	string	任意	EventBridge に SLS ログコンテンツの読み取りを権限付与するために使用されるロール名。Resource Access Management (RAM) コンソールでロールを作成する際、「Alibaba Cloud サービス」を選択し、「信頼できるサービス」を「EventBridge」に設定します。	testRole
SourcePrometheusParameters	object	任意	Prometheus イベントソースのパラメーター。
RegionId	string	任意	リージョン ID。	cn-hangzhou
ClusterId	string	任意	クラスター ID。	c83555068b6******ad213f565f209
DataType	string	任意	データの型。	JSON
Labels	string	任意	ラベル。	__name__=.*
RoleName	string	任意
ExternalLabels	string	任意
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"
WorkerParameters	object	任意	Kafka インスタンスの構成。	{ "group.id": "connect-eb-cluster-KAFKA_CONNECTORC", "offset.storage.topic": "connect-eb-offset-KAFKA_CONNECTOR_yjqC8K5ewC", "config.storage.topic": "connect-eb-config-KAFKA_CONNECTOR_yjqC8K5ewC", "status.storage.topic": "connect-eb-status-KAFKA_CONNECTOR_yjqC8K5ewC", "consumer.group.id": "connector-eb-cluster-KAFKA_CONNECTOR_yjqC8K5ewC-mongo-sink", "bootstrap.servers": "alikafka-post:9092" }
ConnectorParameters	object	任意	コネクタパラメーター。
Name	string	任意	コネクタ名。	test-name
Config	object	任意	コネクタの構成。	{ "connector.class": "com.mongodb.kafka.connect.MongoSinkConnector", "tasks.max": "1", "topics": "sourceA,sourceB" }
SourceApacheKafkaParameters	object	任意	オープンソース Kafka のパラメーターセット。
Bootstraps	string	任意	ブートストラップサーバー。
Topic	string	任意	Topic 名。
ConsumerGroup	string	任意	コンシューマーグループ名。
OffsetReset	string	任意	消費オフセットパラメーター。 latest に設定すると最大オフセットからデータを読み取ります。earliest に設定すると最小オフセットからデータを読み取ります。earliest 設定は未使用グループの初回初期化時のみサポートされます。
ValueDataType	string	任意	データの型。有効な値: Text Binary Json。
VpcId	string	任意	Kafka ソースの VPC ID。
VSwitchIds	string	任意	Kafka ソースの vSwitch ID リスト。
SecurityGroupId	string	任意	Kafka ソースのセキュリティグループ ID。
NetworkType	string	任意	Kafka ネットワークタイプ。
SecurityProtocol	string	任意	Kafka セキュリティプロトコルタイプ。有効な値: SASL_SSL PLAINTEXT SASL_PLAINTEXT。
SaslMechanism	string	任意	Kafka SASL 認証メカニズム。
SaslUser	string	任意	Kafka SASL 認証ユーザー名。
SaslPassword	string	任意	Kafka SASL 認証パスワード。
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 証明書を認証するために使用されます。フォーマット: Base64 エンコードされた PEM フォーマット、通常 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)。クライアント秘密鍵を格納する Key Management サービスインスタンスを特定するために使用されます。フォーマット例: '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 コンテンツを直接格納）の場合、このパラメーターを空のままにします。
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 : single。 element : element	single
LoadFormat	string	任意	ドキュメントローダー。列挙値: TextLoader : TextLoader。	TextLoader
Delimiter	string	任意	デリミタ。チャンクロードモードでは、このデリミタがテキストチャンク識別子として機能します。デフォルト値: 改行文字 \n。	\n
SourceOpenSourceRabbitMQParameters	object	任意
Endpoint	string	任意
VirtualHostName	string	任意
QueueName	string	任意
BodyDataType	string	任意
Username	string	任意
Password	string	任意
VpcId	string	任意
VSwitchIds	string	任意
SecurityGroupId	string	任意
NetworkType	string	任意
AuthType	string	任意
SourceEventBusParameters	object	任意
EventBusName	string	任意
EventRuleName	string	任意
SourceMySQLParameters	SourceMySQLParameters	任意
SourcePostgreSQLParameters	SourcePostgreSQLParameters	任意
SourceRabbitMQMetaParameters	SourceRabbitMQMetaParameters	任意
SourceRabbitMQMsgSyncParameters	SourceRabbitMQMsgSyncParameters	任意
SourceFeiShuDocsParameters	SourceFeiShuDocsParameters	任意
Metadata	string	任意
Sink	object	任意	イベントターゲット。シンクタイプを 1 つだけ指定する必要があります。
SinkMNSParameters	object	任意	MNS イベントターゲット。
QueueName	object	任意	ターゲットサービスタイプはメッセージキュー (旧 MNS) です。
Value	string	任意	Simple メッセージキュー (旧 MNS) キューの名前。	MyQueue
Form	string	任意	変換フォーマット。デフォルト値: CONSTANT。列挙値: CONSTANT : CONSTANT。	CONSTANT
Template	string	任意	テンプレート。	The value of ${key} is ${value}!
Body	object	任意	メッセージ本文。
Value	string	任意	変換前の値。	{ "key": "value" }
Form	string	任意	変換フォーマット。列挙値: JSONPATH : JSONPATH。 CONSTANT : CONSTANT。 TEMPLATE : TEMPLATE。	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 : CONSTANT。	CONSTANT
Template	string	任意	テンプレート。	The value of ${key} is ${value}!
SinkEventHouseParameters	object	任意	イベントターゲット名。
CatalogName	string	任意	カタログ名。	demo
NamespaceName	string	任意	ターゲットテーブルの名前空間。	name1
EventTableName	string	任意	ターゲットテーブルの名前。	demo-table
MappingRules	array<object>	任意	フィールドマッピングルール。
	array<object>	任意	フィールドマッピングルール。
ColumnValue	object	任意	カラム値抽出ルール。
Value	string	任意	The extraction path, such as $.data.value.name.	$.data.value
Form	string	任意	The transformation method, such as JSONPATH.	JSONPATH
Template	string	任意	The template configuration.	The value of ${key} is ${value}!
ColumnName	string	任意	The column name.	age
ColumnType	string	任意	The column type.	text
SinkRabbitMQParameters	object	任意	The parameters for the RabbitMQ sink.
InstanceId	object	任意	The target service type is ApsaraMQ for RabbitMQ.
Value	string	任意	ApsaraMQ for RabbitMQ インスタンスのインスタンス ID。	a5ff91ad4f3f24947887fe184fc2****
Form	string	任意	The transformation format. Default value: CONSTANT. 列挙値: CONSTANT : CONSTANT。	CONSTANT
Template	string	任意	テンプレート。	The value of ${key} is ${value}!
VirtualHostName	object	任意	ApsaraMQ for RabbitMQ インスタンスの vhost 名。
Value	string	任意	The vhost name of the ApsaraMQ for RabbitMQ instance. [_single.params.Sink.props.SinkRabbitMQParameters.VirtualHost	rabbit-host
Form	string	任意	The transformation format. Default value: CONSTANT. 列挙値: CONSTANT : 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	任意	テンプレート。	The value of ${key} is ${value}!
Exchange	object	任意	The Exchange mode. This parameter is required only when TargetType is set to Exchange.
Value	string	任意	The name of the exchange on the ApsaraMQ for RabbitMQ instance.	a_exchange
Form	string	任意	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	任意	テンプレート。	The value of ${key} is ${value}!
RoutingKey	object	任意	The routing rule for messages. This parameter is required only when TargetType is set to Exchange.
Value	string	任意	The routing rule for messages.	housekeeping
Form	string	任意	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	任意	テンプレート。	The value of ${key} is ${value}!
QueueName	object	任意	The Queue mode. This parameter is required only when TargetType is set to Queue.
Value	string	任意	The name of the queue in 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	任意	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 parameters for the Kafka sink.
InstanceId	object	任意	The event target type is ApsaraMQ for Kafka.
Value	string	任意	インスタンス ID。	Defaut_1283278472_s****
Form	string	任意	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	任意	テンプレート。	The value of ${key} is ${value}!
Topic	object	任意	Topic 名。
Value	string	任意	The name of the topic.	test
Form	string	任意	The transformation format. Default value: 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: directly 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 matching field value as the target topic name. [_single.params.Sink.props.SinkKafkaParameters.DynamicTopic
Value	string	任意	The value.
Form	string	任意	The transformation type. Valid values: CONSTANT: constant. JSONPATH: extract from upstream based on a JSONPath expression.
Template	string	任意	テンプレート。
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 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 higher data safety. Data loss occurs only if both the primary and secondary nodes go down.
Value	string	任意	The acknowledgment mode for writing to Kafka. Valid values: 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 and carries 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	任意	テンプレート。	The value of ${key} is ${value}!
Key	object	任意	The message key.
Value	string	任意	The message key.	key
Form	string	任意	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	任意	テンプレート。	The value of ${key} is ${value}!
Value	object	任意	The message body.
Value	string	任意	The value before transformation.	{ "key": "value" }
Form	string	任意	The transformation format.	TEMPLATE
Template	string	任意	テンプレート。	The value of ${key} is ${value}!
Headers	object	任意
Value	string	任意
Form	string	任意
Template	string	任意
CompressionType	string	任意
SinkApacheKafkaParameters	object	任意	The description.
Bootstraps	string	任意	The initial endpoint of the Kafka cluster.
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: directly 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 matching field value as the target topic name. [_single.params.Sink.props.SinkKafkaParameters.DynamicTopic
Value	string	任意	The value.
Form	string	任意	The transformation type. Valid values: CONSTANT: constant. JSONPATH: extract from upstream based on a JSONPath expression.
Template	string	任意	テンプレート。
Topic	string	任意
Acks	string	任意
Key	object	任意
Value	string	任意
Form	string	任意
Template	string	任意
Value	object	任意
Value	string	任意
Form	string	任意
Template	string	任意
Headers	object	任意
Value	string	任意
Form	string	任意
Template	string	任意
SecurityProtocol	string	任意
SaslMechanism	string	任意
SaslUser	string	任意
SslKeystoreCertificateChain	string	任意	[Required for mutual authentication] The Kafka client certificate chain. This parameter is 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, followed by intermediate CA certificates, with the root CA certificate being optional). Concatenate the PEM file contents, each starting with '-----BEGIN CERTIFICATE-----' and ending with '-----END CERTIFICATE-----', and then Base64-encode the result.
SslKeyPassword	string	任意	[Required for encrypted private keys] The Kafka client private key password. This parameter is required 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 validity 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 starts with '-----BEGIN CERTIFICATE-----' and ends with '-----END CERTIFICATE-----'). If Kafka uses a self-signed certificate, provide the CA certificate that issued the certificate.
SslKeystoreKey	object	任意	[Required for bidirectional authentication] The SSL private key configuration object. When the Kafka server enables bidirectional SSL authentication, you must provide the client private key. Only KMS pattern is supported: specify the Key Management EPS resource that stores the private key by using KmsArn. The system retrieves the private key content from KMS only in memory, which provides higher security. Configuration example: {"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 Key Management Service instance that stores the client private key. Format example: 'acs:kms:ap-southeast-1:123456789:secret/ssl-keystore-key-xxxx'. You can find 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":"..."}', set this parameter to 'ssl_keystore_key'. If the KMS secret is in plain text mode (directly storing the PEM content of the private key), leave this parameter empty.
CompressionType	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	任意
SinkFcParameters	object	任意	The function target.
ServiceName	object	任意	The service name.
Value	string	任意	The service name.	myService
Form	string	任意	The transformation format. Default value: CONSTANT. 列挙値: CONSTANT : CONSTANT。	CONSTANT
Template	string	任意	テンプレート。	The value of ${key} is ${value}!
FunctionName	object	任意	The function name.
Value	string	任意	The function name.	myFunction
Form	string	任意	The transformation format. Default value: CONSTANT. 列挙値: CONSTANT : CONSTANT。	CONSTANT
Template	string	任意	テンプレート。	The value of ${key} is ${value}!
Concurrency	object	任意	The delivery concurrency. Minimum value: 1.
Value	string	任意	The delivery concurrency. Minimum value: 1.	1
Form	string	任意	The transformation format. Default value: CONSTANT. 列挙値: CONSTANT : CONSTANT。	CONSTANT
Template	string	任意	テンプレート。	The value of ${key} is ${value}!
Qualifier	object	任意	The service version.
Value	string	任意	The service version.	LATEST
Form	string	任意	The transformation format. Default value: CONSTANT. 列挙値: CONSTANT : 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 : Async Sync : Sync	Async
Form	string	任意	The transformation format. Default value: CONSTANT. 列挙値: CONSTANT : CONSTANT。	CONSTANT
Template	string	任意	テンプレート。	The value of ${key} is ${value}!
Body	object	任意	The content body sent to the function.
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. For more information, see Event transformation. 列挙値: JSONPATH : JSONPATH。 CONSTANT : CONSTANT。 ORIGINAL : ORIGINAL TEMPLATE : TEMPLATE。	TEMPLATE
Template	string	任意	テンプレート。	The value of ${key} is ${value}!
DataFormat	object	任意
Value	string	任意
Form	string	任意
Template	string	任意
SinkRocketMQParameters	object	任意	Sink RocketMQ Parameters
InstanceId	object	任意	The event target type is ApsaraMQ for RocketMQ.
Value	string	任意	The instance ID of the ApsaraMQ 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 ApsaraMQ for RocketMQ instance.
Value	string	任意	The topic name on the ApsaraMQ for RocketMQ instance.	Mytopic
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}!
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	任意	インスタンスタイプ。
Value	string	任意	インスタンスタイプ。有効な値: Cloud_4: Alibaba Cloud ApsaraMQ for RocketMQ 4.0 インスタンス（デフォルト） Cloud_5: Alibaba Cloud ApsaraMQ for RocketMQ 5.0 インスタンス SelfBuilt: セルフマネージド Apache RocketMQ クラスター	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	任意	None.
VpcId	object	任意	The VPC ID.
Value	string	任意	The VPC ID.	vbr-8vb835n3zf9shwlvb****
Form	string	任意	The event transformation format. Default value: CONSTANT.	CONSTANT
Template	string	任意	None.
VSwitchIds	object	任意	vSwitch ID。
Value	string	任意	vSwitch ID。	vbr-8vb835n3zf9shwl****mp
Form	string	任意	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	任意	None.
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	任意	The network type. Valid values: PublicNetwork PrivateNetwork	PublicNetwork
Form	string	任意	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	任意	None.
DeliveryOrderType	object	任意
Value	string	任意
Form	string	任意
Template	string	任意
ShardingKey	object	任意
Value	string	任意
Form	string	任意
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	任意
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	任意	The event source type.
InstanceType	string	任意
InstanceId	string	任意
Topic	object	任意
Value	string	任意
Form	string	任意
Template	string	任意
ConsumeTimestamp	object	任意
Value	string	任意
Form	string	任意
Template	string	任意
Group	object	任意
Value	string	任意
Form	string	任意
Template	string	任意
SinkApacheRocketMQCheckpointParameters	object	任意	The event source type.
Topic	object	任意
Value	string	任意
Form	string	任意
Template	string	任意
ConsumeTimestamp	object	任意
Value	string	任意
Form	string	任意
Template	string	任意
Group	object	任意
Value	string	任意
Form	string	任意
Template	string	任意
InstanceEndpoint	string	任意
InstanceUsername	string	任意
InstancePassword	string	任意
NetworkType	string	任意
VpcId	string	任意
VSwitchId	string	任意
SecurityGroupId	string	任意
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	任意	None.
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	任意	None.
Topic	object	任意	The topic where the log resides, corresponding to the Simple Log Service reserved field "topic".
Value	string	任意	The topic of the log, which corresponds to the Simple Log Service reserved field "topic".	testTopic
Form	string	任意	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	任意	None.
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 conditions 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	任意	To grant authorization to the event bus EventBridge to use this role to read Simple Log Service log content, the following conditions must be met: when creating the role used by the service in the Resource Access Management (RAM) console, select "Alibaba Cloud Service", and set the trusted service to "event bus".	testRole
Form	string	任意	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	任意	None.
ContentType	object	任意	The Simple Log Service data format. You can select the default format or configure a specific key-value format. 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	任意	テンプレート。
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	任意	The DataHub topic name.	demo-topic
Form	string	任意	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	任意	None.
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	任意	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	任意	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	任意	None.
RoleName	object	任意	The task role name.
Value	string	任意	The task role name.	test-role
Form	string	任意	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	任意	None.
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 : CONSTANT。	CONSTANT
Template	string	任意	テンプレート。
ExecutionName	object	任意	The execution name.
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. 列挙値: JSONPATH : JSONPATH。 CONSTANT : CONSTANT。 TEMPLATE : TEMPLATE。	CONSTANT
Template	string	任意	テンプレート。
Input	object	任意	The execution input information.
Value	string	任意	The execution input information.	123
Form	string	任意	The transformation format. Valid values: ORIGINAL: complete event. JSONPATH: partial event. CONSTANT: constant. TEMPLATE: template. For more information, see Event transformation. 列挙値: JSONPATH : JSONPATH。 CONSTANT : CONSTANT。 ORIGINAL : ORIGINAL TEMPLATE : TEMPLATE。	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 : 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 : CONSTANT。	CONSTANT
Template	string	任意	The template style. Leave this parameter empty when Form is set to CONSTANT.
HeaderParameters	object	任意	The data structure of request header parameters.
Value	string	任意	The value. Valid values: If Form is set to CONSTANT: a constant value. If Form is set to JSONPATH: content extracted by using a JSONPath expression. If Form is set to TEMPLATE: a template variable. 説明 The Value field cannot exceed 10,240 characters.	name
Form	string	任意	The transformation format. 列挙値: JSONPATH : JSONPATH。 CONSTANT : CONSTANT。 TEMPLATE : TEMPLATE。	TEMPLATE
Template	string	任意	The HTTP request header template style. Specify this parameter when Form is set to TEMPLATE. The result of event content transformation must be in JSON format.	{ "user_name":"${name}" }
AuthorizationType	object	任意	The authentication method.
Value	string	任意	The authentication method. 列挙値: BASIC_AUTH : BASIC_AUTH	BASIC_AUTH
Form	string	任意	The transformation format. Default value: CONSTANT. 列挙値: CONSTANT : CONSTANT。	CONSTANT
Template	string	任意	None.
Username	object	任意	The username.
Value	string	任意	The username.	****admin
Form	string	任意	The transformation format. Default value: CONSTANT.	CONSTANT
Template	string	任意	None.
Password	object	任意	The password.
Value	string	任意	The password.	*****
Form	string	任意	The transformation format. Default value: CONSTANT. 列挙値: CONSTANT : CONSTANT。	CONSTANT
Template	string	任意	None.
Data	object	任意	The metric content.
Value	string	任意	The metric content.	$.data
Form	string	任意	The transformation format. Default value: JSONPATH.	JSAONPATH
Template	string	任意	テンプレート。
NetworkType	object	任意	ネットワークタイプ。
Value	string	任意	ネットワークタイプ。列挙値: PrivateNetwork : PrivateNetwork。 PublicNetwork : PublicNetwork。	PrivateNetwork
Form	string	任意	The transformation format. Default value: CONSTANT. 列挙値: CONSTANT : CONSTANT。	CONSTANT
Template	string	任意	None.
VpcId	object	任意	The VPC ID.
Value	string	任意	The VPC ID.	i-2ze7u5i17mbqtx1p****
Form	string	任意	The transformation format. Default value: CONSTANT. 列挙値: CONSTANT : CONSTANT。	CONSTANT
Template	string	任意	None.
VSwitchId	object	任意	vSwitch ID。
Value	string	任意	vSwitch ID。	vsw-dwaafds****
Form	string	任意	The transformation format. Default value: CONSTANT. 列挙値: CONSTANT : CONSTANT。	CONSTANT
Template	string	任意	None.
SecurityGroupId	object	任意	セキュリティグループ ID。
Value	string	任意	セキュリティグループ ID。	sg-mw43*****
Form	string	任意	The transformation format. Default value: CONSTANT. 列挙値: CONSTANT : CONSTANT。	CONSTANT
Template	string	任意	None.
SinkCustomizedKafkaParameters	object	任意	The Sink Kafka parameters.
InstanceId	string	任意	The instance ID of ApsaraMQ for 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	任意	The instance configuration.	{ "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. 列挙値: Delete : Delete Upsert : Upsert	Upsert
Network	string	任意	ネットワークタイプ。列挙値: PrivateNetwork : PrivateNetwork。 PublicNetwork : 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 transformation format. 列挙値: JSONPATH : JSONPATH。 TEMPLATE : TEMPLATE。	JSONPATH
Value	string	任意	The value. Valid values: If Form is set to JSONPATH: content extracted by using a JSONPath expression. If Form is set to 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 transformation format. 列挙値: JSONPATH : JSONPATH。 CONSTANT : CONSTANT。	CONSTANT
Value	string	任意	The value. Valid values: If Form is set to CONSTANT: a constant value. If Form is set to JSONPATH: content extracted by using a JSONPath expression. 説明 The Value field cannot exceed 10,240 characters.	default
Template	string	任意	None.	${partition}
Vector	object	任意	The vector of the record to insert into DashVector.
Form	string	任意	The transformation format. 列挙値: JSONPATH : JSONPATH。	JSONPATH
Value	string	任意	The content extracted by using a JSONPath expression. 説明 The Value field cannot exceed 10,240 characters.	$.data.messageBody
Template	string	任意	None.	${vector}
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>	任意	The attribute column.
Name	object	任意	The property name.
Form	string	任意	Form	CONSTANT
Value	string	任意	Value	content
Template	string	任意	Template
Type	object	任意	The DashVector property type.
Form	string	任意	Form	CONSTANT
Value	string	任意	Value	STRING
Template	string	任意	Template
Value	object	任意	The property value.
Form	string	任意	Form	JSONPATH
Value	string	任意	Value	$.data.content
Template	string	任意	Template	${content}
SinkOpenSourceRabbitMQParameters	object	任意
Endpoint	string	任意
VirtualHostName	string	任意
TargetType	string	任意
Exchange	string	任意
QueueName	string	任意
Username	string	任意
Password	string	任意
VpcId	string	任意
VSwitchIds	string	任意
SecurityGroupId	string	任意
NetworkType	string	任意
AuthType	string	任意
RoutingKey	object	任意
Form	string	任意
Value	string	任意
Template	string	任意
Body	object	任意
Form	string	任意
Value	string	任意
Template	string	任意
MessageId	object	任意
Form	string	任意
Value	string	任意
Template	string	任意
Properties	object	任意
Form	string	任意
Value	string	任意
Template	string	任意
SinkBaiLianParameters	SinkBaiLianParameters	任意
SinkDataWorksTriggerParameters	SinkDataWorksTriggerParameters	任意
SinkHttpsParameters	SinkHttpsParameters	任意
SinkApiDestinationParameters	SinkApiDestinationParameters	任意
SinkOSSParameters	SinkOSSParameters	任意
SinkRabbitMQMetaParameters	SinkRabbitMQMetaParameters	任意
SinkRabbitMQMsgSyncParameters	SinkRabbitMQMsgSyncParameters	任意
SinkMQTTParameters	SinkMQTTParameters	任意
SinkAgentRunParameters	SinkAgentRunParameters	任意
RunOptions	object	任意	The runtime environment parameters.
MaximumTasks	integer	任意	The concurrency.	2
ErrorsTolerance	string	任意	The exception tolerance policy. Valid values: NONE: No exceptions are tolerated. ALL: All exceptions are tolerated.	ALL
RetryStrategy	object	任意	The retry policy when event delivery fails.
PushRetryStrategy	string	任意	The retry policy. Valid values: BACKOFF_RETRY: backoff retry. 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	任意
VpcId	string	任意
VSwitchIds	string	任意
SecurityGroupId	string	任意
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 Alibaba Cloud Resource Name (ARN) of the cloud service, such as the ARN of a function in Function Compute.
Arn	string	任意	The Alibaba Cloud Resource Name (ARN) of the cloud service, 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	任意
EmbeddingTransformParameters	EmbeddingTransformParameters	任意
Tags	array<object>	任意	The tag list. A maximum of 20 items are supported.
	object	任意
Key	string	任意	The tag key.
Value	string	任意	The tag value.

レスポンスフィールド

フィールド	型	説明	例
	object	The request parameters.
Message	string	The error message.	The name [xxxx] of event streaming in request is already exist!
RequestId	string	The request ID.	B896B484-F16D-59DE-9E23-DD0E5C36****
Data	object	The returned data.
EventStreamingARN	string	The Alibaba Cloud Resource Name (ARN) of the event stream.	acs:eventbridge:cn-hangzhou:164901546557****:eventstreaming/myeventstreaming
Code	string	The response code. Valid values: Success: The request was successful. Other values: An error occurred. For more information, see Error codes.	Success
Success	boolean	Returns true if the operation was successful.	true

例

成功レスポンス

JSONJSON

{
  "Message": "The name [xxxx] of event streaming in request is already exist!",
  "RequestId": "B896B484-F16D-59DE-9E23-DD0E5C36****",
  "Data": {
    "EventStreamingARN": "acs:eventbridge:cn-hangzhou:164901546557****:eventstreaming/myeventstreaming"
  },
  "Code": "Success",
  "Success": true
}

エラーコード

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

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

変更履歴

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