イベントストリームの詳細を取得します。
操作説明
イベントストリームの詳細を取得します。
今すぐお試しください
テスト
RAM 認証
|
アクション |
アクセスレベル |
リソースタイプ |
条件キー |
依存アクション |
|
eventbridge:GetEventStreaming |
get |
*EventStreaming
|
なし | なし |
リクエストパラメーター
|
パラメーター |
型 |
必須 / 任意 |
説明 |
例 |
| EventStreamingName |
string |
必須 |
クエリするイベントストリームの名前。 |
myeventstreaming |
レスポンスフィールド
|
フィールド |
型 |
説明 |
例 |
|
object |
応答パラメーター。 |
||
| Message |
string |
エラーメッセージ。 |
The event streaming [xxxx] not existed! |
| RequestId |
string |
リクエスト ID。 |
7892F480-58C9-5067-AB35-8A7BEF**** |
| Data |
object |
返されたデータ。 |
|
| EventStreamingName |
string |
イベントストリームの名前。 |
rocketmq-sync |
| Description |
string |
イベントストリームの説明。 |
RocketMQ-to-RocketMQ |
| Source |
object |
イベントソース。 |
|
| SourceMNSParameters |
object |
Simple メッセージキュー (旧 MNS) ソースのパラメーター。 |
|
| RegionId |
string |
リージョン ID。 |
cn-hangzhou |
| QueueName |
string |
Simple メッセージキュー (旧 MNS) インスタンスのキュー名。 |
demo |
| IsBase64Decode |
boolean |
Base64 デコードが有効かどうかを示します。 |
true |
| SourceRabbitMQParameters |
object |
RabbitMQ ソースのパラメーター。 |
|
| RegionId |
string |
リージョン ID。 |
cn-hangzhou |
| InstanceId |
string |
ApsaraMQ for RabbitMQ メッセージキューインスタンスのインスタンス ID。 |
i-f8z9a9mcgwri1c1i**** |
| VirtualHostName |
string |
ApsaraMQ for RabbitMQ メッセージキューインスタンスのバーチャルホスト名。 |
eb-connect |
| QueueName |
string |
ApsaraMQ for RabbitMQ メッセージキューインスタンスのキュー名。 |
comp |
| SourceRocketMQParameters |
object |
RocketMQ ソースのパラメーター。 |
|
| RegionId |
string |
ApsaraMQ for RocketMQ メッセージキューインスタンスのリージョン ID。 |
cn-hangzhou |
| InstanceId |
string |
ApsaraMQ for RocketMQ メッセージキューインスタンスのインスタンス ID。 |
i-f8zbher64dlm58pl**** |
| Topic |
string |
メッセージの Topic。 |
topic_add_anima |
| Tag |
string |
メッセージのフィルタータグ。 |
v1 |
| Offset |
string |
メッセージの消費オフセット。有効な値: CONSUME_FROM_LAST_OFFSET: 最大オフセットから消費を開始します。 CONSUME_FROM_FIRST_OFFSET: 最小オフセットから消費を開始します。 CONSUME_FROM_TIMESTAMP: 指定した時間のオフセットから消費を開始します。 |
CONSUMEFROMLASTOFFSET |
| GroupID |
string |
ApsaraMQ for RocketMQ メッセージキューインスタンスのグループ ID。 |
GID_group1 |
| Timestamp |
integer |
タイムスタンプ。このパラメーターは Offset パラメーターが CONSUME_FROM_TIMESTAMP に設定されている場合にのみ有効です。 |
1636597951964 |
| InstanceType |
string |
インスタンスタイプ。有効な値:
|
Cloud_4 |
| InstanceEndpoint |
string |
インスタンスエンドポイント。 |
reg****-vpc.cn-zhangjiakou.aliyuncs.com |
| AuthType |
string |
認証タイプ。 |
ACL |
| InstanceUsername |
string |
インスタンスのユーザー名。 |
xxxa |
| InstancePassword |
string |
インスタンスのパスワード。 |
xxxa |
| InstanceVpcId |
string |
インスタンスの VPC ID。 |
vpc-m5e3sv4b12345**** |
| InstanceVSwitchIds |
string |
インスタンスの vSwitch ID。 |
vsw-m5ev8asdc6h12**** |
| InstanceSecurityGroupId |
string |
インスタンスのセキュリティグループ ID。 |
sg-m5edtu24f12345**** |
| InstanceNetwork |
string |
インスタンスのネットワークタイプ。有効な値:
|
PublicNetwork |
| BodyDataType |
string |
メッセージ本文のエンコード形式。有効な値:
|
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 |
| SourceRocketMQCheckpointParameters |
object |
RocketMQ チェックポイントソースのパラメーター。 |
|
| RegionId |
string |
リージョン ID。 |
cn-hangzhou |
| InstanceType |
string |
インスタンスタイプ。有効な値:
|
Cloud_4 |
| InstanceId |
string |
インスタンス ID。 |
rmp-cn-jte3w****** |
| Topics |
array |
メッセージの Topic。 |
|
|
string |
メッセージの Topic。 |
opic_add_anima |
|
| SourceApacheRocketMQCheckpointParameters |
object |
RocketMQ チェックポイントソースのパラメーター。 |
|
| RegionId |
string |
リージョン ID。 |
cn-hangzhou |
| InstanceId |
string |
RocketMQ インスタンス ID。 |
MQ_INST_164901546557****_BAAN**** |
| Topics |
array |
Topic のリスト。 |
|
|
string |
消費する Topic のリスト。 |
["Topic_1","Topic_2"] |
|
| InstanceEndpoint |
string |
インスタンスエンドポイント。 |
registry-vpc.cn-hangzhou.aliyuncs.com |
| InstanceUsername |
string |
インスタンスのユーザー名。 |
admin |
| InstancePassword |
string |
インスタンスのパスワード。 |
123456 |
| NetworkType |
string |
ネットワークタイプ。 |
PrivateNetwork |
| VpcId |
string |
VPC ID。 |
vpc-adw1awdw***** |
| VSwitchId |
string |
vSwitch ID。 |
vsw-dwaafds**** |
| SecurityGroupId |
string |
セキュリティグループ ID。 |
sg-mw43***** |
| SourceKafkaParameters |
object |
Kafka ソースのパラメーター。 |
|
| RegionId |
string |
インスタンスのリージョン ID。 |
cn-hangzhou |
| InstanceId |
string |
インスタンス ID。 |
i-bp1fbtrnqmjvgq66**** |
| Topic |
string |
Topic 名。 |
topic_empower_1642473600414 |
| ConsumerGroup |
string |
Topic をサブスクライブする消費者のグループ ID。 |
GID_TEST |
| OffsetReset |
string |
オフセット。 |
latest |
| Network |
string |
ネットワーク構成。デフォルト値: Default。VPC ネットワークの場合、このパラメーターを PublicNetwork に設定します。 |
Default |
| VpcId |
string |
VPC ID。 |
vpc-2zehizpoendb3**** |
| VSwitchIds |
string |
vSwitch ID。 |
vsw-wz9qqeovkwjxlu9uc**** |
| SecurityGroupId |
string |
セキュリティグループ ID。 |
sg-2vcgdxz7o1n9zapp**** |
| ValueDataType |
string |
エンコードおよびデコードのフォーマット。有効な値:
|
Text |
| SourceMQTTParameters |
object |
MQTT ソースのパラメーター。 |
|
| RegionId |
string |
リージョン ID。 |
cn-shanghai |
| InstanceId |
string |
インスタンス ID。 |
i-2ze06wqdwk0uq14k**** |
| Topic |
string |
Topic 名。 |
TOPIC-cainiao-pcs-wms-instock-noPrealertPrintLabel |
| BodyDataType |
string |
メッセージ本文のエンコード形式。有効な値:
|
JSON |
| NetworkType |
string |
ネットワークタイプ。 |
|
| VpcId |
string |
VPC ID。 |
|
| VSwitchIds |
string |
vSwitch ID。 |
|
| SecurityGroupId |
string |
セキュリティグループ ID。 |
|
| SourceDTSParameters |
object |
Data Transmission Service (DTS) ソースのパラメーター。 |
|
| TaskId |
string |
タスク ID。 |
f86e5814-b223-482c-b768-3b873297**** |
| BrokerUrl |
string |
データサブスクリプションチャンネルのネットワークアドレスとポート番号。 |
|
| Topic |
string |
データサブスクリプションチャンネルのサブスクリプション Topic。 |
TP_TEST_UNDERWRITE_ISSUE |
| Sid |
string |
コンシューマーグループ ID。 |
HD1 |
| Username |
string |
コンシューマーグループのアカウント。 |
admin |
| Password |
string |
コンシューマーグループアカウントのパスワード。 |
admin**** |
| InitCheckPoint |
string |
消費チェックポイント。SDK クライアントが最初のデータ Record を消費する時間のタイムスタンプです。値は UNIX タイムスタンプです。 |
1620962769 |
| SourceSLSParameters |
object |
Simple Log Service (SLS) ソースのパラメーター。 |
|
| Project |
string |
Simple Log Service プロジェクト。 |
dmmzk |
| LogStore |
string |
Simple Log Service の Logstore。 |
waf-logstore |
| ConsumerGroup |
string |
コンシューマーグループ。 |
|
| ConsumePosition |
string |
消費開始位置。最も古い位置または最新の位置を選択でき、それぞれ「begin」と「end」に対応します。秒単位で指定した時間から消費を開始することもできます。 |
begin |
| RoleName |
string |
イベントバス EventBridge に SLS ログコンテンツの読み取りを権限付与するロール名。Resource Access Management (RAM) コンソールでロールを作成する際、信頼できるエンティティとして Alibaba Cloud サービスを選択し、信頼できるサービスとしてイベントバスを選択します。 |
testRole |
| SourcePrometheusParameters |
object |
Prometheus イベントソースのパラメーター。 |
|
| RegionId |
string |
リージョン ID。 |
cn-hangzhou |
| ClusterId |
string |
クラスター ID。 |
c83555068b6******ad213f565f209 |
| DataType |
string |
データの型。 |
Json |
| Labels |
string |
ラベル。 |
__name__=.* |
| RoleName |
string |
タスクロール名。 |
test-role |
| ExternalLabels |
string |
イベントストリームに追加される外部ラベル。 |
{"env":"test"} |
| SourceCustomizedKafkaParameters |
object |
カスタム Kafka イベントソースのパラメーター。 |
|
| InstanceId |
string |
Message Queue for Apache Kafka メッセージキューインスタンスのインスタンス ID。 |
r-8vb64581862c**** |
| SourceCustomizedKafkaConnectorParameters |
object |
カスタム Apache Kafka コネクタイベントソースのパラメーター。 |
|
| ConnectorPackageUrl |
string |
OSS リソース ZIP パッケージのダウンロード URL。 |
"https://examplebucket.oss-cn-hangzhou.aliyuncs.com/testDoc/Old_Homebrew/2024-06-26%2022%3A34%3A08/opt/homebrew/homebrew/Library/Homebrew/test/support/fixtures/cask/AppWithBinary.zip?OSSAccessKeyId=ri&Expires=1725539627&Signature=rb8q3OpV2i3gZJ" |
| ConnectorParameters |
object |
コネクタパラメーター。 |
|
| Name |
string |
コネクタ名。 |
test-name |
| Config |
object |
コネクタ構成。 |
{ "connector.class": "com.mongodb.kafka.connect.MongoSinkConnector", "tasks.max": "1", "topics": "sourceA,sourceB" } |
| WorkerParameters |
object |
インスタンス構成。 |
{ "group.id": "connect-eb-cluster-KAFKA_CONNECTORC", "offset.storage.topic": "connect-eb-offset-KAFKA_CONNECTOR_yjqC8K5ewC", "config.storage.topic": "connect-eb-config-KAFKA_CONNECTOR_yjqC8K5ewC", "status.storage.topic": "connect-eb-status-KAFKA_CONNECTOR_yjqC8K5ewC", "consumer.group.id": "connector-eb-cluster-KAFKA_CONNECTOR_yjqC8K5ewC-mongo-sink", "bootstrap.servers": "alikafka-post:9092" } |
| SourceApacheKafkaParameters |
object |
||
| Bootstraps |
string |
||
| Topic |
string |
||
| ConsumerGroup |
string |
||
| OffsetReset |
string |
||
| ValueDataType |
string |
||
| VpcId |
string |
||
| VSwitchIds |
string |
||
| SecurityGroupId |
string |
||
| NetworkType |
string |
||
| SecurityProtocol |
string |
||
| SaslMechanism |
string |
||
| SaslUser |
string |
||
| SaslPassword |
string |
||
| SslTruststoreCertificates |
string |
[SSL 必須] Kafka サーバー信頼証明書。Kafka ブローカーの SSL 証明書を検証し、中間者攻撃を防止するために使用されます。フォーマット: Base64 エンコードされた PEM フォーマットで、通常は Kafka サーバーの CA 証明書またはサーバー証明書を含みます。例: CA 証明書の PEM ファイルコンテンツを Base64 エンコードします ('-----BEGIN CERTIFICATE-----' で始まり '-----END CERTIFICATE-----' で終わることを確認してください)。Kafka が自己署名証明書を使用している場合は、その証明書を発行した CA 証明書を提供してください。 |
|
| SslKeystoreCertificateChain |
string |
[相互認証必須] Kafka クライアント証明書チェーン。Kafka サーバーが相互 SSL 認証を有効にしている場合に必須です (ssl.client.auth=required)。フォーマット: Base64 エンコードされた PEM フォーマットで、クライアント証明書と完全な証明書チェーン (クライアント証明書が最初、中間 CA 証明書が次、ルート CA 証明書はオプション) を含みます。注意: 各 PEM ファイルコンテンツが '-----BEGIN CERTIFICATE-----' で始まり '-----END CERTIFICATE-----' で終わることを確認し、連結されたコンテンツを Base64 エンコードしてください。 |
|
| SslKeyPassword |
string |
[暗号化された秘密鍵に必須] Kafka クライアント秘密鍵パスワード。クライアント秘密鍵が暗号化されている場合に必須です (PEM ファイルに 'Proc-Type: 4,ENCRYPTED' または 'ENCRYPTED' マーカーが含まれている場合)。秘密鍵が暗号化されていない場合は空のままにしてください。注意: このパスワードは秘密鍵の復号にのみ使用され、Kafka 認証とは無関係です。 |
|
| SslKeystoreKey |
object |
[双方向認証必須] SSL 秘密鍵構成オブジェクト。Kafka サーバーが双方向 SSL 認証を有効にしている場合に必須です。キーは KMS モードのみをサポートします: KmsArn を使用して秘密鍵を格納する Key Management Service (KMS) リソースを指定します。システムはセキュリティを高めるため、メモリ内でのみ KMS から秘密鍵コンテンツを取得します。構成例: {"KmsArn": "acs:kms:cn-hangzhou:123456789:secret/ssl-key-xxxx", "KmsSecretValueKey": "keystore_private_key"} |
|
| KmsArn |
string |
[必須] SSL 秘密鍵を格納する KMS リソース ARN。クライアント秘密鍵を格納する KMS インスタンスを特定するために使用されます。フォーマット例: 'acs:kms:cn-hangzhou:123456789:secret/ssl-keystore-key-xxxx'。KMS コンソールで対応するキーの ARN を確認できます。 |
|
| KmsSecretValueKey |
string |
[KMS KV モード] KMS シークレット内のキー名。KMS シークレットがキーバリュー (KV) 構造で格納されている場合、このパラメーターを指定して SSL 秘密鍵に対応するキーを示します。例: KMS シークレットが '{"ssl_keystore_key":"-----BEGIN PRIVATE KEY-----...","ssl_truststore_key":"..."}' の場合、'ssl_keystore_key' を指定します。KMS シークレットがプレーンテキストモード (秘密鍵の PEM コンテンツを直接格納) の場合、このパラメーターは空のままにしてください。 |
|
| SourceOSSParameters |
object |
OSS イベントソースのパラメーター。 |
|
| RoleName |
string |
イベントバス EventBridge に OSS ファイルの読み取りを権限付与するロール名。ロールには少なくとも OSS に対する読み取り専用権限が必要です。 |
eventbridge_oss_role |
| BucketName |
string |
OSS バケットの名前。 |
bucket_abc |
| Prefix |
string |
ファイルパスプレフィックス。 |
fun/document/ |
| LoadMode |
string |
データロードモード。single の値は単一ドキュメントロードを示し、element の値はチャンクロードを示します。有効な値: single/element。デフォルト値: single。 |
single |
| LoadFormat |
string |
ドキュメントローダー。 |
TextLoader |
| Delimiter |
string |
デリミタ。チャンクロードモードでは、このデリミタがテキストチャンク識別子として使用されます。デフォルトのデリミタは改行文字 です。 |
\n |
| SourceOpenSourceRabbitMQParameters |
object |
オープンソース RabbitMQ ソースのパラメーター。 |
|
| Endpoint |
string |
オープンソース RabbitMQ インスタンスのエンドポイント。 |
192.168.1.100:5672 |
| VirtualHostName |
string |
オープンソース RabbitMQ インスタンスのバーチャルホスト名。 |
eb-connect |
| QueueName |
string |
オープンソース RabbitMQ インスタンスのキュー名。 |
demo |
| BodyDataType |
string |
メッセージ本文のエンコード形式。有効な値:
|
Json |
| Username |
string |
ユーザー名。 |
admin |
| Password |
string |
パスワード。 |
****** |
| VpcId |
string |
VPC ID。 |
vpc-bp1vllc1lnw1v657****** |
| VSwitchIds |
string |
vSwitch ID。 |
vsw-uf65zhil5oukof5****** |
| SecurityGroupId |
string |
セキュリティグループ ID。 |
sg-2ze65razphjfz3****** |
| NetworkType |
string |
ネットワークタイプ。有効な値:
|
PrivateNetwork |
| AuthType |
string |
認証タイプ。 |
ACL |
| SourceEventBusParameters |
object |
イベントバスソースのパラメーター。 |
|
| EventBusName |
string |
イベントバスの名前。 |
demo |
| EventRuleName |
string |
イベントルールの名前。 |
test |
| SourceMySQLParameters | SourceMySQLParameters |
MySQL ソースのパラメーター。 |
|
| SourcePostgreSQLParameters | SourcePostgreSQLParameters | ||
| SourceRabbitMQMetaParameters | SourceRabbitMQMetaParameters | ||
| SourceRabbitMQMsgSyncParameters | SourceRabbitMQMsgSyncParameters | ||
| SourceFeiShuDocsParameters | SourceFeiShuDocsParameters | ||
| Metadata |
string |
||
| FilterPattern |
string |
イベントフィルタールール。指定しない場合、すべてのイベントが一致します。 |
|
| Transforms |
array<object> |
イベント転換の構成。 |
|
|
object |
クラウドリソースの Alibaba Cloud リソースネーム(ARN)。例えば、Function Compute の関数の ARN です。 |
||
| Arn |
string |
クラウドリソースの Alibaba Cloud リソースネーム (ARN)。例: Function Compute の関数の ARN。 |
acs:fc:cn-hangzhou:*****:services/demo-service.LATEST/functions/demo-func |
| DashScopeTransformParameters |
DashScopeTransformParameters |
||
| BaiLianAgentTransformParameters |
BaiLianAgentTransformParameters |
||
| Sink |
object |
イベントターゲット。 |
|
| SinkMNSParameters |
object |
Simple メッセージキュー (旧 MNS) イベントターゲット。 |
|
| QueueName |
object |
ターゲットサービスタイプは Simple メッセージキュー (旧 MNS) です。 |
|
| Value |
string |
Simple メッセージキュー (旧 MNS) インスタンスのキュー名。 |
MyQueue |
| Form |
string |
The transformation format. Default value: CONSTANT. |
CONSTANT |
| Template |
string |
テンプレートスタイル。 |
|
| Body |
object |
メッセージ本文。 |
|
| Value |
string |
変換前の値。 |
{ "key": "value" } |
| Form |
string |
The transformation format. |
TEMPLATE |
| Template |
string |
テンプレートスタイル。 |
The value of ${key} is ${value}! |
| IsBase64Encode |
object |
Base64 デコードが有効かどうかを示します。 |
|
| Value |
string |
Base64 エンコーディングを有効にするかどうかを指定します。 |
true |
| Form |
string |
The event transformation format. Default value: CONSTANT. |
CONSTANT |
| Template |
string |
テンプレートスタイル。 |
|
| SinkRabbitMQParameters |
object |
RabbitMQ シンクのパラメーター。 |
|
| InstanceId |
object |
ターゲットサービスタイプは ApsaraMQ for RabbitMQ メッセージキューです。 |
|
| Value |
string |
ApsaraMQ for RabbitMQ メッセージキューインスタンスのインスタンス ID。 |
e5c9b727-e06c-4d7e-84d5-f8ce644e**** |
| Form |
string |
The transformation format. Default value: CONSTANT. |
CONSTANT |
| Template |
string |
テンプレートスタイル。 |
The value of ${key} is ${value}! |
| VirtualHostName |
object |
ApsaraMQ for RabbitMQ メッセージキューインスタンスのバーチャルホスト名。 |
|
| Value |
string |
ApsaraMQ for RabbitMQ メッセージキューインスタンスのバーチャルホスト名。 |
rabbit-host |
| Form |
string |
The transformation format. Default value: CONSTANT. |
CONSTANT |
| Template |
string |
テンプレートスタイル。 |
|
| TargetType |
object |
ターゲットタイプ。 |
|
| Value |
string |
ターゲットタイプ。有効な値:
|
Exchange/Queue |
| Form |
string |
変換フォーマット。デフォルト値: CONSTANT。 |
CONSTANT |
| Template |
string |
テンプレートスタイル。 |
The value of ${key} is ${value}! |
| Exchange |
object |
Exchange モード。 このパラメーターは TargetType が Exchange に設定されている場合にのみ必須です。 |
|
| Value |
string |
メッセージキュー for RabbitMQ インスタンスの Exchange 名。 |
a_exchange |
| Form |
string |
変換フォーマット。デフォルト値: CONSTANT。 |
CONSTANT |
| Template |
string |
テンプレートスタイル。 |
The value of ${key} is ${value}! |
| RoutingKey |
object |
メッセージのルーティングルール。 このパラメーターは TargetType が Exchange に設定されている場合に |
|
| Value |
string |
The routing rule of the message. |
housekeeping |
| Form |
string |
The transformation format. Default value: CONSTANT. |
CONSTANT |
| Template |
string |
テンプレートスタイル。 |
The value of ${key} is ${value}! |
| QueueName |
object |
Queue モード。 このパラメーターは TargetType が Queue に設定されている場合にのみ必須です。 |
|
| Value |
string |
The name of the queue on the instance. |
MyQueue |
| Form |
string |
The transformation format. Default value: CONSTANT. |
CONSTANT |
| Template |
string |
テンプレートスタイル。 |
The value of ${key} is ${value}! |
| Body |
object |
メッセージ本文。 |
|
| Value |
string |
The value before transformation. |
{ "key": "value" } |
| Form |
string |
The transformation format. |
TEMPLATE |
| Template |
string |
テンプレートスタイル。 |
The value of ${key} is ${value}! |
| MessageId |
object |
メッセージ ID。 |
|
| Value |
string |
The value before transformation. |
{ "key": "value" } |
| Form |
string |
The transformation format. |
TEMPLATE |
| Template |
string |
テンプレートスタイル。 |
The value of ${key} is ${value}! |
| Properties |
object |
The filter properties. |
|
| Value |
string |
The value before transformation. |
{ "key": "value" } |
| Form |
string |
The transformation format. |
TEMPLATE |
| Template |
string |
テンプレートスタイル。 |
The value of ${key} is ${value}! |
| SinkFcParameters |
object |
関数ターゲット。 |
|
| ServiceName |
object |
The service name. |
|
| Value |
string |
サービス名。 |
myService |
| Form |
string |
The transformation format. Default value: CONSTANT. |
CONSTANT |
| Template |
string |
テンプレートスタイル。 |
The value of ${key} is ${value}! |
| FunctionName |
object |
The function name. |
|
| Value |
string |
The function name. |
mFunction |
| Form |
string |
The transformation format. Default value: CONSTANT. |
CONSTANT |
| Template |
string |
テンプレートスタイル。 |
The value of ${key} is ${value}! |
| Concurrency |
object |
The delivery concurrency. Minimum value: 1. |
|
| Value |
string |
配信の同時実行数。最小値: 1。 |
1 |
| Form |
string |
変換フォーマット。デフォルト値: CONSTANT。 |
CONSTANT |
| Template |
string |
テンプレートスタイル。 |
The value of ${key} is ${value}! |
| Qualifier |
object |
The service version. |
|
| Value |
string |
サービスバージョン。 |
LATEST |
| Form |
string |
The transformation format. Default value: CONSTANT. |
CONSTANT |
| Template |
string |
テンプレートスタイル。 |
The value of ${key} is ${value}! |
| InvocationType |
object |
The invocation type. Valid values:
|
|
| Value |
string |
The invocation type. Valid values:
|
Async |
| Form |
string |
変換フォーマット。デフォルト値: CONSTANT。 |
CONSTANT |
| Template |
string |
テンプレートスタイル。 |
The value of ${key} is ${value}! |
| Body |
object |
関数に送信されるコンテンツ本文。 |
|
| Value |
string |
変換前の値。 |
{ "key": "value" } |
| Form |
string |
変換フォーマット。有効な値:
詳細については、イベント転換を参照してください。 |
TEMPLATE |
| Template |
string |
テンプレートスタイル。 |
The value of ${key} is ${value}! |
| DataFormat |
object |
イベントコンテンツのフォーマット変換ルール。 |
|
| Value |
string |
The value before transformation. |
{ "key": "value" } |
| Form |
string |
変換フォーマット。有効な値:
|
JSONPATH |
| Template |
string |
テンプレートスタイル。 |
$.data.key |
| SinkKafkaParameters |
object |
The parameters for the Kafka sink. |
|
| InstanceId |
object |
The target service type is MSMQ for Apache Kafka. |
|
| Value |
string |
インスタンス ID。 |
Defaut_1283278472_s**** |
| Form |
string |
変換フォーマット。デフォルト値: CONSTANT。 |
CONSTANT |
| Template |
string |
テンプレートスタイル。 |
The value of ${key} is ${value}! |
| DynamicTopic |
object |
Specifies the target topic strategy for message routing. If both the topic parameter and the DynamicTopic parameter are specified, the DynamicTopic parameter takes precedence. Two configuration modes are supported: 1. Static constant mode: Specify a fixed topic name string (for example, "order_created"). All messages are sent to this topic. 2. Dynamic extraction mode: Specify a standard JSONPath expression (for example, "$.user.id" or "$.metadata.category"). The system parses the upstream message body and extracts the value of the matching field as the target topic name. |
|
| Value |
string |
The value. |
|
| Form |
string |
The transformation type. Valid values: CONSTANT: fixed value. JSONPATH: extracted from upstream based on the path. |
|
| Template |
string |
The template. [_single.resp.200.props.Data.Sink.SinkKafkaParameters.Topic |
|
| Topic |
object |
Topic 名。 |
|
| Value |
string |
Topic 名。 |
test |
| Form |
string |
変換フォーマット。デフォルト値: CONSTANT。 |
CONSTANT |
| Template |
string |
テンプレートスタイル。 |
The value of ${key} is ${value}! |
| CompressionType |
string |
||
| Acks |
object |
Kafka への書き込み時の確認応答モード:
|
|
| Value |
string |
Kafka への書き込み時の確認応答モード:
|
1 |
| Form |
string |
The transformation format. Default value: CONSTANT. |
CONSTANT |
| Template |
string |
テンプレートスタイル。 |
The value of ${key} is ${value}! |
| Key |
object |
メッセージキー。 |
|
| Value |
string |
The message key. |
key |
| Form |
string |
変換フォーマット。デフォルト値: CONSTANT。 |
CONSTANT |
| Template |
string |
テンプレートスタイル。 |
The value of ${key} is ${value}! |
| Headers |
object |
The additional metadata of the Kafka message. |
|
| Value |
string |
The value before transformation. |
{ "key": "value" } |
| Form |
string |
The transformation format. Valid values:
|
CONSTANT |
| Template |
string |
テンプレートスタイル。 |
The value of ${key} is ${value}! |
| Value |
object |
メッセージ本文。 |
|
| Value |
string |
変換前の値。 |
{ "key": "value" } |
| Form |
string |
The transformation format. |
TEMPLATE |
| Template |
string |
テンプレートスタイル。 |
The value of ${key} is ${value}! |
| SinkApacheKafkaParameters |
object |
説明情報。 |
|
| Bootstraps |
string |
||
| Topic |
string |
||
| DynamicTopic |
object |
メッセージルーティングのターゲット Topic 戦略を指定します。topic パラメーターと DynamicTopic パラメーターの両方が指定されている場合、DynamicTopic パラメーターが優先されます。2 つの構成モードがサポートされています: 1. 静的定数モード: 固定の Topic 名文字列を指定します (例: "order_created")。すべてのメッセージがこの Topic に送信されます。 2. 動的抽出モード: 標準の JSONPath 式を指定します (例: "$.user.id" または "$.metadata.category")。システムがアップストリームメッセージ本文を解析し、一致するフィールドの値をターゲット Topic 名として抽出します。 |
|
| Value |
string |
The value. |
|
| Form |
string |
The transformation type. Valid values: CONSTANT: fixed value. JSONPATH: extracted from upstream based on the path. |
|
| Template |
string |
The template. [_single.resp.200.props.Data.Sink.SinkKafkaParameters.Topic |
|
| Acks |
string |
||
| CompressionType |
string |
||
| Key |
object |
||
| Value |
string |
||
| Form |
string |
||
| Template |
string |
||
| Headers |
object |
||
| Value |
string |
||
| Form |
string |
||
| Template |
string |
||
| Value |
object |
||
| Value |
string |
||
| Form |
string |
||
| Template |
string |
||
| SecurityProtocol |
string |
||
| SaslMechanism |
string |
||
| SaslUser |
string |
||
| VpcId |
object |
||
| Value |
string |
||
| Form |
string |
||
| Template |
string |
||
| VSwitchIds |
object |
||
| Value |
string |
||
| Form |
string |
||
| Template |
string |
||
| SecurityGroupId |
object |
||
| Value |
string |
||
| Form |
string |
||
| Template |
string |
||
| NetworkType |
object |
||
| Value |
string |
||
| Form |
string |
||
| Template |
string |
||
| SaslPassword |
string |
||
| SslTruststoreCertificates |
string |
[SSL 必須] Kafka サーバー信頼証明書。Kafka ブローカーの SSL 証明書の正当性を認証し、中間者攻撃を防止するために使用されます。フォーマット: Base64 エンコードされた PEM フォーマットで、通常は Kafka サーバーの CA 証明書またはサーバー証明書を含みます。例: CA 証明書の PEM ファイルコンテンツを Base64 エンコードします ('-----BEGIN CERTIFICATE-----' で始まり '-----END CERTIFICATE-----' で終わることを確認してください)。Kafka が自己署名証明書を使用している場合は、その証明書を発行した CA 証明書を提供してください。 |
|
| SslKeystoreCertificateChain |
string |
[Required for mutual authentication] The Kafka client certificate chain. Required when the Kafka server enables mutual SSL authentication (ssl.client.auth=required). Format: Base64-encoded PEM format, containing the client certificate and the complete certificate chain (client certificate first, intermediate CA certificate next, root CA certificate optional). Note: Ensure each PEM file content starts with '-----BEGIN CERTIFICATE-----' and ends with '-----END CERTIFICATE-----', then Base64-encode the concatenated content. |
|
| SslKeyPassword |
string |
[Required for encrypted private key] The Kafka client private key password. Required when the client private key is encrypted (the PEM file contains 'Proc-Type: 4,ENCRYPTED' or 'ENCRYPTED' markers). Leave empty if the private key is not encrypted. Note: This password is used only to decrypt the private key and is unrelated to Kafka authentication. |
|
| SslKeystoreKey |
object |
[双方向認証必須] SSL 秘密鍵構成オブジェクト。Kafka サーバーが双方向 SSL 認証を有効にしている場合、クライアント秘密鍵が必要です。キーは KMS パターンのみをサポートします: KmsArn を使用して秘密鍵を格納する Key Management EPS リソースを指定します。システムはセキュリティを高めるため、メモリ内でのみ KMS から秘密鍵コンテンツを取得します。構成例: {"KmsArn": "acs:kms:ap-southeast-1:123456789:secret/ssl-key-xxxx", "KmsSecretValueKey": "keystore_private_key"} |
|
| KmsArn |
string |
[Required] The KMS resource ARN that stores the SSL private key. Used to locate the KMS instance that stores the client private key. Format example: 'acs:kms:cn-hangzhou:123456789:secret/ssl-keystore-key-xxxx'. You can view the ARN of the corresponding key in the KMS console. |
|
| KmsSecretValueKey |
string |
[KMS KV mode] The key name in the KMS secret. When the KMS secret is stored in a key-value (KV) structure, specify this parameter to indicate the key that corresponds to the SSL private key. Example: if the KMS secret is '{"ssl_keystore_key":"-----BEGIN PRIVATE KEY-----...","ssl_truststore_key":"..."}', specify 'ssl_keystore_key'. Leave this parameter empty if the KMS secret is in plain text mode (directly stores the PEM content of the private key). |
|
| SinkRocketMQParameters |
object |
シンク RocketMQ パラメーター。 |
|
| InstanceId |
object |
The target service type is MSMQ for RocketMQ. |
|
| Value |
string |
The instance ID of the MSMQ for RocketMQ instance. |
MQ_INST_164901546557****_BAAN**** |
| Form |
string |
The transformation format. Default value: CONSTANT. |
CONSTANT |
| Template |
string |
テンプレートスタイル。 |
The value of ${key} is ${value}! |
| Topic |
object |
The topic of the MSMQ for RocketMQ instance. |
|
| Value |
string |
メッセージキュー for RocketMQ インスタンスの Topic 名。 |
Mytopic |
| Form |
string |
変換フォーマット。デフォルト値: CONSTANT。 |
CONSTANT |
| Template |
string |
テンプレートスタイル。 |
The value of ${key} is ${value}! |
| Body |
object |
メッセージ本文。 |
|
| Value |
string |
変換前の値。 |
{ "key": "value" } |
| Form |
string |
変換フォーマット。 |
TEMPLATE |
| Template |
string |
テンプレートスタイル。 |
The value of ${key} is ${value}! |
| Properties |
object |
フィルタープロパティ。 |
|
| Value |
string |
変換前の値。 |
{ "key": "value" } |
| Form |
string |
変換フォーマット。 |
TEMPLATE |
| Template |
string |
テンプレートスタイル。 |
The value of ${key} is ${value}! |
| Keys |
object |
The filter properties. |
|
| Value |
string |
The value before transformation. |
{ "key": "value" } |
| Form |
string |
変換フォーマット。 |
TEMPLATE |
| Template |
string |
テンプレートスタイル。 |
The value of ${key} is ${value}! |
| Tags |
object |
フィルタープロパティ。 |
|
| Value |
string |
変換前の値。 |
{ "key": "value" } |
| Form |
string |
The transformation format. |
TEMPLATE |
| Template |
string |
テンプレートスタイル。 |
The value of ${key} is ${value}! |
| InstanceType |
object |
インスタンスタイプ。有効な値:
|
|
| Value |
string |
The instance type. Valid values:
|
Cloud_4 |
| Form |
string |
The transformation format. Default value: CONSTANT. |
CONSTANT |
| Template |
string |
None. |
|
| InstanceEndpoint |
object |
インスタンスエンドポイント。 |
|
| Value |
string |
インスタンスエンドポイント。 |
vbr-8vbsvkkbpf3vb0zef**** |
| Form |
string |
The transformation format. Default value: CONSTANT. |
CONSTANT |
| Template |
string |
None. |
|
| InstanceUsername |
object |
インスタンスのユーザー名。 |
|
| Value |
string |
インスタンスのユーザー名。 |
admin |
| Form |
string |
The transformation format. Default value: CONSTANT. |
CONSTANT |
| Template |
string |
None. |
|
| InstancePassword |
object |
インスタンスのパスワード。 |
|
| Value |
string |
インスタンスのパスワード。 |
admin**** |
| Form |
string |
The transformation format. Default value: CONSTANT. |
CONSTANT |
| Template |
string |
なし。 |
|
| VpcId |
object |
VPC ID。 |
|
| Value |
string |
VPC ID。 |
vbr-8vb835n3zf9shwlvb**** |
| Form |
string |
イベント変換フォーマット。デフォルト値: CONSTANT。 |
CONSTANT |
| Template |
string |
None. |
|
| VSwitchIds |
object |
vSwitch ID。 |
|
| Value |
string |
vSwitch ID。 |
vbr-8vb835n3zf9shwl****mp |
| Form |
string |
変換フォーマット。デフォルト値: CONSTANT。 |
CONSTANT |
| Template |
string |
なし。 |
|
| SecurityGroupId |
object |
セキュリティグループ ID。 |
|
| Value |
string |
セキュリティグループ ID。 |
b4bf375515f6440f942e3a20c33d**** |
| Form |
string |
The transformation format. Default value: CONSTANT. |
CONSTANT |
| Template |
string |
None. |
|
| Network |
object |
The network type. Valid values:
|
|
| Value |
string |
ネットワークタイプ。有効な値:
|
PublicNetwork |
| Form |
string |
The transformation format. Default value: CONSTANT. |
CONSTANT |
| Template |
string |
なし。 |
|
| DeliveryOrderType |
object |
The delivery order type of messages. Optional. The default value is concurrent delivery. |
|
| Value |
string |
配信順序タイプ。有効な値:
|
Concurrently |
| Form |
string |
The transformation format. Default value: CONSTANT. |
CONSTANT |
| Template |
string |
テンプレートスタイル。 |
|
| ShardingKey |
object |
メッセージのシャーディングキー。 説明
|
|
| Value |
string |
シャーディングキーの値。 |
order_id |
| Form |
string |
変換フォーマット。デフォルト値: CONSTANT。 |
CONSTANT |
| Template |
string |
テンプレートスタイル。 |
|
| SinkDorisParameters |
object |
||
| QueryEndpoint |
object |
||
| Value |
string |
||
| Form |
string |
||
| Template |
string |
||
| FeHttpEndpoint |
object |
||
| Value |
string |
||
| Form |
string |
||
| Template |
string |
||
| BeHttpEndpoint |
object |
||
| Value |
string |
||
| Form |
string |
||
| Template |
string |
||
| UserName |
object |
||
| Value |
string |
||
| Form |
string |
||
| Template |
string |
||
| Password |
object |
||
| Value |
string |
||
| Form |
string |
||
| Template |
string |
||
| Database |
object |
||
| Value |
string |
||
| Form |
string |
||
| Template |
string |
||
| Table |
object |
||
| Value |
string |
||
| Form |
string |
||
| Template |
string |
||
| Body |
object |
||
| Value |
string |
||
| Form |
string |
||
| Template |
string |
||
| NetworkType |
object |
||
| Value |
string |
||
| Form |
string |
||
| Template |
string |
||
| VpcId |
object |
||
| Value |
string |
||
| Form |
string |
||
| Template |
string |
||
| VSwitchIds |
object |
||
| Value |
string |
||
| Form |
string |
||
| Template |
string |
||
| SecurityGroupId |
object |
||
| Value |
string |
||
| Form |
string |
||
| Template |
string |
||
| SinkRocketMQCheckpointParameters |
object |
シンク RocketMQ チェックポイントパラメーター。 |
|
| InstanceType |
string |
インスタンスタイプ。有効な値:
|
Cloud_4 |
| InstanceId |
string |
インスタンス ID。 |
MQ_INST_164901546557****_BAAN**** |
| Topic |
object |
The topic of the MSMQ for RocketMQ instance. |
|
| Value |
string |
The topic name of the MSMQ for RocketMQ instance. |
Mytopic |
| Form |
string |
The transformation format. Default value: CONSTANT. |
CONSTANT |
| Template |
string |
テンプレートスタイル。 |
|
| Group |
object |
The Group ID of the consumer group. |
|
| Value |
string |
Group ID |
GID_EVENTBRIDGE_1736234****** |
| Form |
string |
変換フォーマット。デフォルト値: CONSTANT。 |
CONSTANT |
| Template |
string |
テンプレートスタイル。 |
|
| ConsumeTimestamp |
object |
メッセージ消費のタイムスタンプ。 |
|
| Value |
string |
The timestamp. |
1570761026400 |
| Form |
string |
The transformation format. Default value: CONSTANT. |
CONSTANT |
| Template |
string |
テンプレートスタイル。 |
|
| SinkApacheRocketMQCheckpointParameters |
object |
シンク Apache RocketMQ チェックポイントパラメーター。 |
|
| Topic |
object |
The topic of the RocketMQ instance. |
|
| Value |
string |
RabbitMQ インスタンスの Topic 名。 |
Mytopic |
| Form |
string |
The transformation format. Default value: CONSTANT. |
CONSTANT |
| Template |
string |
テンプレートスタイル。 |
|
| Group |
object |
The Group ID of the consumer group. |
|
| Value |
string |
Group ID |
GID_EVENTBRIDGE_1736234****** |
| Form |
string |
The transformation format. Default value: CONSTANT. |
CONSTANT |
| Template |
string |
テンプレートスタイル。 |
|
| ConsumeTimestamp |
object |
メッセージ消費のタイムスタンプ。 |
|
| Value |
string |
The timestamp. |
1570761026400 |
| Form |
string |
変換フォーマット。デフォルト値: CONSTANT。 |
CONSTANT |
| Template |
string |
テンプレートスタイル。 |
|
| InstanceEndpoint |
string |
インスタンスエンドポイント。 |
192.168.1.1:9876 |
| InstanceUsername |
string |
The username required for authentication. |
admin |
| InstancePassword |
string |
ユーザー名のパスワード。 |
**** |
| NetworkType |
string |
ネットワークタイプ。 |
PrivateNetwork |
| VpcId |
string |
VPC ID。 |
vpc-2zeccak5pb0j3ay****** |
| VSwitchId |
string |
vSwitch ID。 |
vsw-uf62oqt1twuevrt****** |
| SecurityGroupId |
string |
セキュリティグループ ID。 |
sg-2ze5bmpw6adn0q****** |
| SinkSLSParameters |
object |
Sink SLS Parameters |
|
| Project |
object |
Simple Log Service プロジェクト。 |
|
| Value |
string |
The Simple Log Service project. |
test-project |
| Form |
string |
変換フォーマット。デフォルト値: CONSTANT。 |
CONSTANT |
| Template |
string |
テンプレートスタイル。 |
|
| LogStore |
object |
The Simple Log Service Logstore. |
|
| Value |
string |
The Simple Log Service Logstore. |
test-logstore |
| Form |
string |
The transformation format. Default value: CONSTANT. |
CONSTANT |
| Template |
string |
テンプレートスタイル。 |
|
| Topic |
object |
The topic where the log resides, corresponding to the Simple Log Service reserved field "topic". |
|
| Value |
string |
The topic where the log resides, corresponding to the Simple Log Service reserved field "topic". |
testTopic |
| Form |
string |
The transformation format. Default value: CONSTANT. |
CONSTANT |
| Template |
string |
テンプレートスタイル。 |
|
| Body |
object |
The content sent to Simple Log Service. |
|
| Value |
string |
The value before transformation. |
{ "key": "value" } |
| Form |
string |
The transformation format. |
TEMPLATE |
| Template |
string |
テンプレートスタイル。 |
The value of ${key} is ${value}! |
| RoleName |
object |
To grant authorization to the event bus EventBridge to use this role to read Simple Log Service log content, the following condition must be met: when creating the role used by the service in the Resource Access Management (RAM) console, select "Alibaba Cloud Service" and set "Trusted Service" to "event bus". |
|
| Value |
string |
イベントバス EventBridge にこのロールを使用して Simple Log Service ログコンテンツの読み取りを権限付与するには、次の条件を満たす必要があります: Resource Access Management (RAM) コンソールでサービスが使用するロールを作成する際、「Alibaba Cloud サービス」を選択し、「信頼できるサービス」を「イベントバス」に設定します。 |
testRole |
| Form |
string |
The transformation format. Default value: CONSTANT. |
CONSTANT |
| Template |
string |
テンプレートスタイル。 |
|
| ContentType |
object |
Simple Log Service のデータ形式。デフォルトフォーマットを選択するか、指定されたキーバリューペアを構成できます。有効な値:
|
|
| Value |
string |
The value before transformation. |
JSON |
| Form |
string |
変換フォーマット。 |
CONSTANT |
| Template |
string |
テンプレートスタイル。 |
|
| ContentSchema |
object |
カスタムログのキーバリューペア。このパラメーターは ContentType が KeyValue に設定されている場合にのみ有効です。各キーバリューペアは Key_n と Value_n で表されます。 |
|
| Value |
string |
変換前の値。 |
{"Key_1":{"form":"CONSTANT","value":"demoKey"},"Value_1":{"form":"JSONPATH","value":"$.data.value"}} |
| Form |
string |
テンプレートスタイル。 |
CONSTANT |
| Template |
string |
テンプレートスタイル。 |
|
| SinkFnfParameters |
object |
The Sink CloudFlow parameters. |
|
| FlowName |
object |
フロー名。 |
|
| Value |
string |
フロー名。 |
test-streaming-fnf |
| Form |
string |
変換フォーマット。デフォルト値: CONSTANT。 |
CONSTANT |
| Template |
string |
テンプレートスタイル。 |
|
| ExecutionName |
object |
実行名。 |
|
| Value |
string |
The execution name. |
123 |
| Form |
string |
The transformation format. Default value: CONSTANT. Valid values:
For more information, see Event transformation. |
CONSTANT |
| Template |
string |
テンプレートスタイル。 |
|
| Input |
object |
The execution input information. |
|
| Value |
string |
実行入力情報。 |
123 |
| Form |
string |
The transformation format. Default value: CONSTANT. |
CONSTANT |
| Template |
string |
テンプレートスタイル。 |
|
| RoleName |
object |
ロール構成。 |
|
| Value |
string |
The role configuration. |
Al****FNF-x**** |
| Form |
string |
変換フォーマット。デフォルト値: CONSTANT。 |
CONSTANT |
| Template |
string |
テンプレートスタイル。 |
|
| SinkDataHubParameters |
object |
The Sink DataHub parameters. |
|
| Project |
object |
The DataHub project name. |
|
| Value |
string |
The DataHub project name. |
demo-project |
| Form |
string |
The transformation format. Default value: CONSTANT. |
CONSTANT |
| Template |
string |
None. |
|
| Topic |
object |
The DataHub topic name. |
|
| Value |
string |
DataHub Topic 名。 |
demo-topic |
| Form |
string |
変換フォーマット。デフォルト値: CONSTANT。 |
CONSTANT |
| Template |
string |
None. |
|
| TopicType |
object |
Topic タイプ。有効な値:
|
|
| Value |
string |
The topic type. Valid values:
|
TUPLE |
| Form |
string |
The transformation format. Default value: CONSTANT. |
CONSTANT |
| Template |
string |
None. |
|
| TopicSchema |
object |
The topic content schema for the TUPLE type. |
|
| Value |
string |
The topic content schema for the TUPLE type. |
{"k1":"value1","k2":"value2"} |
| Form |
string |
変換フォーマット。 |
TEMPLATE |
| Template |
string |
テンプレートスタイル。 |
{"k1":"${k1}","k2":"${k2}"} |
| Body |
object |
The Record content template for the BLOB type. |
|
| Value |
string |
BLOB タイプの Record コンテンツテンプレート。 |
|
| Form |
string |
The transformation format. |
ORIGINAL |
| Template |
string |
なし。 |
|
| RoleName |
object |
タスクロール名。 |
|
| Value |
string |
タスクロール名。 |
test-role |
| Form |
string |
The transformation format. Default value: CONSTANT. |
CONSTANT |
| Template |
string |
None. |
|
| SinkCustomizedKafkaParameters |
object |
シンク Kafka パラメーター。 |
|
| InstanceId |
string |
The instance ID of the MSMQ for Apache Kafka instance. |
90be1f96-4229-4535-bb76-34b4f6fb**** |
| SinkCustomizedKafkaConnectorParameters |
object |
シンク Kafka コネクタパラメーター。 |
|
| ConnectorPackageUrl |
string |
The OSS file download URL. |
"https://examplebucket.oss-cn-hangzhou.aliyuncs.com/testDoc/Old_Homebrew/2024-06-26%2022%3A34%3A08/opt/homebrew/homebrew/Library/Homebrew/test/support/fixtures/cask/AppWithBinary.zip?OSSAccessKeyId=ri&Expires=1725539627&Signature=rb8q3OpV******" |
| ConnectorParameters |
object |
現在の ZIP パッケージ内のプロパティファイルを解析します。 |
|
| Name |
string |
コネクタ名。 |
mongo-sink |
| Config |
object |
コネクタ構成。 |
{ "connector.class": "com.mongodb.kafka.connect.MongoSinkConnector", "tasks.max": "1", "topics": "sourceA,sourceB" } |
| WorkerParameters |
object |
インスタンス構成。 |
{ "group.id": "connect-eb-cluster-KAFKA_CONNECTORC", "offset.storage.topic": "connect-eb-offset-KAFKA_CONNECTOR_yjqC8K5ewC", "config.storage.topic": "connect-eb-config-KAFKA_CONNECTOR_yjqC8K5ewC", "status.storage.topic": "connect-eb-status-KAFKA_CONNECTOR_yjqC8K5ewC", "consumer.group.id": "connector-eb-cluster-KAFKA_CONNECTOR_yjqC8K5ewC-mongo-sink", "bootstrap.servers": "alikafka-post:9092" } |
| SinkDashVectorParameters |
object |
シンク DashVector パラメーター。 |
|
| InstanceId |
string |
インスタンス ID。 |
vrs-cn-lbj3ru1*** |
| Collection |
string |
コレクション名。 |
collection1 |
| ApiKey |
string |
DashVector コンソールで作成された API キー。 |
Q34nExQH7sQ**** |
| Operation |
string |
DashVector データベースの操作タイプ。 |
Upsert |
| Network |
string |
ネットワークタイプ。 |
PublicNetwork |
| PrimaryKeyId |
object |
Record の挿入または削除に使用するプライマリキー ID。このフィールドが指定されていない場合、ランダムなプライマリキー ID が使用されます。 |
|
| Form |
string |
変換フォーマット。 |
JSONPATH |
| Value |
string |
Note: The Value field cannot exceed 10,240 characters. |
$.data.requestId |
| Template |
string |
プライマリキー ID テンプレート。このパラメーターは Form が TEMPLATE に設定されている場合にのみ必須です。 |
${ID} |
| Partition |
object |
The partition. Default value: default. |
|
| Form |
string |
The transformation format. |
CONSTANT |
| Value |
string |
注意: Value フィールドは 10,240 文字を超えることはできません。 |
default |
| Template |
string |
None. |
|
| Vector |
object |
DashVector に挿入する Record のベクター。 |
|
| Form |
string |
The transformation format. |
JSONPATH |
| Value |
string |
The content extracted by JSONPath. Note: The Value field cannot exceed 10,240 characters. |
$.data.messageBody |
| Template |
string |
None. |
|
| DashVectorSchemaParameters |
array<object> |
The schema field definition of the table entry when inserting into DashVector. The result of event content transformation must be in JSON format. |
|
|
array<object> |
|||
| Name |
object |
||
| Form |
string |
||
| Value |
string |
||
| Template |
string |
||
| Type |
object |
||
| Form |
string |
||
| Value |
string |
||
| Template |
string |
||
| Value |
object |
||
| Form |
string |
||
| Value |
string |
||
| Template |
string |
||
| SinkOpenSourceRabbitMQParameters |
object |
Sink Open Source RabbitMQ Parameters |
|
| Endpoint |
string |
The endpoint. |
192.168.1.1:9876 |
| VirtualHostName |
string |
The virtual host name of RabbitMQ. |
vhost1 |
| TargetType |
string |
メッセージ配信のターゲットタイプ。このパラメーターは TargetType が Exchange に設定されている場合にのみ有効です。 |
Exchange |
| Exchange |
string |
The exchange name in RabbitMQ. |
my-exchange |
| QueueName |
string |
The queue name in RabbitMQ. This parameter takes effect only when TargetType is set to Queue. |
my-queue |
| Username |
string |
RabbitMQ インスタンスにアクセスするためのユーザー名。 |
admin |
| Password |
string |
The password for accessing the RabbitMQ instance. |
**** |
| VpcId |
string |
VPC ID。 |
vpc-uf6of9452b2pba82c **** |
| VSwitchIds |
string |
vSwitch ID。 |
vsw-uf6of9452b2pba82c **** |
| SecurityGroupId |
string |
セキュリティグループ ID。 |
sg-uf6of9452b2pba82c **** |
| NetworkType |
string |
ネットワークタイプ。 |
PublicNetwork |
| AuthType |
string |
認証タイプ。 |
ACL |
| RoutingKey |
object |
The message routing key. |
|
| Form |
string |
変換フォーマット。デフォルト値: CONSTANT。 |
CONSTANT |
| Value |
string |
The routing key value. |
{"Form": "CONSTANT", "Value": "my-routing-key"} |
| Template |
string |
テンプレートスタイル。 |
The value of ${key} is ${value}! |
| Body |
object |
メッセージ本文コンテンツ。 |
|
| Form |
string |
変換フォーマット。デフォルト値: CONSTANT。 |
CONSTANT |
| Value |
string |
生データの値。 |
{"key": "value"} |
| Template |
string |
テンプレートスタイル。 |
The value of ${key} is ${value}! |
| MessageId |
object |
The unique identifier of the message. |
|
| Form |
string |
The transformation format. Default value: CONSTANT. |
CONSTANT |
| Value |
string |
メッセージ ID の値。 |
12345 |
| Template |
string |
テンプレートスタイル。 |
|
| Properties |
object |
The additional properties of the message. |
|
| Form |
string |
The transformation format. Default value: CONSTANT. |
CONSTANT |
| Value |
string |
The property content. |
{"env": "prod"} |
| Template |
string |
テンプレートスタイル。 |
The value of ${key} is ${value}! |
| SinkBaiLianParameters | SinkBaiLianParameters |
Sink BaiLian Parameters |
|
| SinkDataWorksTriggerParameters | SinkDataWorksTriggerParameters | ||
| SinkHttpsParameters |
SinkHttpsParameters |
HTTPS ターゲットパラメーター。 |
|
| SinkApiDestinationParameters | SinkApiDestinationParameters |
ApiDestination ターゲットパラメーター。 |
|
| SinkOSSParameters | SinkOSSParameters | ||
| SinkRabbitMQMetaParameters | SinkRabbitMQMetaParameters | ||
| SinkRabbitMQMsgSyncParameters | SinkRabbitMQMsgSyncParameters | ||
| SinkMQTTParameters | SinkMQTTParameters | ||
| SinkAgentRunParameters | SinkAgentRunParameters | ||
| RunOptions |
object |
The runtime environment parameters. |
|
| MaximumTasks |
integer |
同時実行数。 |
2 |
| RetryStrategy |
object |
イベント配信失敗時のリトライポリシー。 |
|
| PushRetryStrategy |
string |
リトライポリシー: BACKOFF_RETRY (バックオフ再試行) または EXPONENTIALDECAY_RETRY (指数関数的減衰リトライ)。 |
BACKOFF_RETRY |
| MaximumEventAgeInSeconds |
number |
最大再試行時間。 |
512 |
| MaximumRetryAttempts |
number |
The maximum number of retry attempts. |
2 |
| ErrorsTolerance |
string |
フォールトトレランスポリシー: NONE (フォールトトレランスなし) または ALL (すべての例外を許容)。 |
ALL |
| DeadLetterQueue |
object |
Specifies whether to enable the dead-letter queue. By default, the dead-letter queue is disabled, and messages that exceed the retry policy are discarded. |
|
| Arn |
string |
デッドレターキューの ARN。 |
acs:ram::155020394332****:role/edskmstoecs |
| Network |
string |
デッドレターキューのネットワークタイプ。 |
PrivateNetwork |
| VpcId |
string |
デッドレターキューが存在する VPC ID。 |
vpc-2zehizpoendb3**** |
| VSwitchIds |
string |
The vSwitch ID where the dead-letter queue resides. |
vsw-m5ev8asdc6h12345**** |
| SecurityGroupId |
string |
デッドレターキューが存在するインスタンスのセキュリティグループ ID。 |
sg-2vcgdxz7o1n9zapp**** |
| BatchWindow |
object |
The batching window. |
|
| CountBasedWindow |
integer |
ウィンドウに含めることができるイベントの最大数。このしきい値に達すると、ウィンドウ内のデータがダウンストリームにプッシュされます。複数 |
100 |
| TimeBasedWindow |
integer |
The maximum time range (in seconds) for events in the window. When this threshold is reached, the data in the window is pushed downstream. If multiple windows exist, data is pushed when any one window meets the threshold. |
10 |
| BusinessOption |
object |
||
| BusinessMode |
string |
||
| MinCapacityUnitCount |
integer |
||
| MaxCapacityUnitCount |
integer |
||
| Throttling |
integer |
||
| Status |
string |
The status of the retrieved event stream. |
RUNNING |
| DetailedStatus |
object |
The detailed status. |
|
| TPS |
number |
1 秒あたりのトランザクション数。 |
5 |
| DelayTime |
integer |
The delay time. |
3 |
| DiffOffset |
integer |
The difference offset. |
0 |
| Extensions |
object |
The extension properties. |
{ "test": "test", "test2": 1 } |
| Code |
string |
The response code. Success indicates a successful operation. Other values indicate error codes. For more information, see Error codes. |
Success |
| Success |
boolean |
Returns true if the operation is successful. |
true |
エラーコード
|
HTTP ステータスコード |
エラーコード |
エラーメッセージ |
説明 |
|---|---|---|---|
| 403 | ServiceNotEnable | Service not enable |
完全なリストについては、「エラーコード」をご参照ください。
変更履歴
完全なリストについては、「変更履歴」をご参照ください。