5.3. Amazon Web Services SNS
5.3.1. camel-aws2-sns-kafka-connector のシンク設定 リンクのコピーリンクがクリップボードにコピーされました!
コネクターの説明: AWS SDK バージョン 2.x を使用して AWS Simple Notification Topic にメッセージを送信します。
camel-aws2-sns-kafka-connector をシンクとして使用する場合、以下の Maven 依存関係を使用してコネクターをサポートするようにしてください。
<dependency>
<groupId>org.apache.camel.kafkaconnector</groupId>
<artifactId>camel-aws2-sns-kafka-connector</artifactId>
<version>x.x.x</version>
<!-- use the same version as your Camel Kafka connector version -->
</dependency>
Kafka コネクションでこのシンクコネクターを使用するには、以下の connector.class を設定する必要があります。
connector.class=org.apache.camel.kafkaconnector.aws2sns.CamelAws2snsSinkConnector
camel-aws2-sns シンクコネクターは、以下に示す 44 個のオプションをサポートします。
| 名前 | 説明 | デフォルト | 必要性 | 優先順位 |
|---|---|---|---|---|
| camel.sink.path.topicNameOrArn | TOPIC 名または ARN。 | null | true | HIGH |
| camel.sink.endpoint.amazonSNSClient | AmazonSNS をクライアントとして使用します。 | null | false | MEDIUM |
| camel.sink.endpoint.autoCreateTopic | トピックの自動作成を設定します。 | true | false | MEDIUM |
| camel.sink.endpoint.headerFilterStrategy | カスタムの HeaderFilterStrategy を使用して、ヘッダーから Camel または Camel からヘッダーにマッピングします。 | null | false | MEDIUM |
| camel.sink.endpoint.kmsMasterKeyId | Amazon SNS の AWS 管理のカスタマーマスターキー (CMK) の ID またはカスタム CMK の ID。 | null | false | MEDIUM |
| camel.sink.endpoint.lazyStartProducer | 最初のメッセージでプロデューサーをレイジーに起動すべきかどうか。レイジーに起動することで、起動時にプロデューサーが失敗し、それによりルートが失敗する可能性がある状況で、CamelContext およびルートの起動を許可します。レイジーな起動を延期すると、Camel のルーティングエラーハンドラー経由でメッセージのルーティング中に起動の失敗を処理できます。最初のメッセージが処理されるときに、プロデューサーの作成および起動に若干時間がかかり、合計処理時間が長くなる可能性があることに注意してください。 | false | false | MEDIUM |
| camel.sink.endpoint.messageDeduplicationIdStrategy | FIFO トピックのみ。メッセージに messageDeduplicationId を設定するストラテジー。useExchangeId または useContentBasedDeduplication のいずれかをオプションとして使用できます。useContentBasedDeduplication オプションでは、メッセージに messageDeduplicationId が設定されません。[useExchangeId] または [useContentBasedDeduplication] のいずれか。 | "useExchangeId" | false | MEDIUM |
| camel.sink.endpoint.messageGroupIdStrategy | FIFO トピックのみ。メッセージに messageGroupId を設定するストラテジー。useConstant、useExchangeId、usePropertyValue のいずれかをオプションとして使用できます。usePropertyValue オプションでは、CamelAwsMessageGroupId プロパティーの値が使用されます。[useConstant]、[useExchangeId]、[usePropertyValue] のいずれか。 | null | false | MEDIUM |
| camel.sink.endpoint.messageStructure | json などの使用するメッセージ構造。 | null | false | MEDIUM |
| camel.sink.endpoint.policy | このトピックのポリシー。デフォルトではクラスパスからロードされますが、classpath:、file:、または http: をプレフィックとして指定して、異なるシステムからリソースをロードすることもできます。 | null | false | MEDIUM |
| camel.sink.endpoint.proxyHost | SNS クライアントをインスタンス化するときにプロキシーホストを定義します。 | null | false | MEDIUM |
| camel.sink.endpoint.proxyPort | SNS クライアントをインスタンス化するときにプロキシーポートを定義します。 | null | false | MEDIUM |
| camel.sink.endpoint.proxyProtocol | SNS クライアントをインスタンス化する際にプロキシープロトコルを定義します。[HTTP] または [HTTPS] のいずれか。 | "HTTPS" | false | MEDIUM |
| camel.sink.endpoint.queueUrl | サブスクライブする queueUrl。 | null | false | MEDIUM |
| camel.sink.endpoint.region | SNS クライアントが機能する必要があるリージョン。このパラメーターを使用する場合、設定には小文字のリージョン名を指定します (例 ap-east-1)。名前 Region.EU_WEST_1.id() を使用する必要があります。 | null | false | MEDIUM |
| camel.sink.endpoint.serverSideEncryptionEnabled | サーバー側の暗号化がトピックで有効であるかどうかを定義します。 | false | false | MEDIUM |
| camel.sink.endpoint.subject | メッセージヘッダー 'CamelAwsSnsSubject' が存在しない場合に使用されるサブジェクト。 | null | false | MEDIUM |
| camel.sink.endpoint.subscribeSNStoSQS | SNS トピックと SQS との間のサブスクリプションを完了する必要があるかどうかを定義します。 | false | false | MEDIUM |
| camel.sink.endpoint.trustAllCertificates | エンドポイントを上書きするときにすべての証明書を信頼する場合。 | false | false | MEDIUM |
| camel.sink.endpoint.useDefaultCredentialsProvider | SNS クライアントが AWS infra インスタンスでクレデンシャルのロードすること、または静的クレデンシャルが渡されることを SNS クライアントが想定すべきかどうかを設定します。 | false | false | MEDIUM |
| camel.sink.endpoint.accessKey | Amazon AWS Access Key | null | false | MEDIUM |
| camel.sink.endpoint.secretKey | Amazon AWS Secret Key | null | false | MEDIUM |
| camel.component.aws2-sns.amazonSNSClient | AmazonSNS をクライアントとして使用します。 | null | false | MEDIUM |
| camel.component.aws2-sns.autoCreateTopic | トピックの自動作成を設定します。 | true | false | MEDIUM |
| camel.component.aws2-sns.configuration | コンポーネントの設定 | null | false | MEDIUM |
| camel.component.aws2-sns.kmsMasterKeyId | Amazon SNS の AWS 管理のカスタマーマスターキー (CMK) の ID またはカスタム CMK の ID。 | null | false | MEDIUM |
| camel.component.aws2-sns.lazyStartProducer | 最初のメッセージでプロデューサーをレイジーに起動すべきかどうか。レイジーに起動することで、起動時にプロデューサーが失敗し、それによりルートが失敗する可能性がある状況で、CamelContext およびルートの起動を許可します。レイジーな起動を延期すると、Camel のルーティングエラーハンドラー経由でメッセージのルーティング中に起動の失敗を処理できます。最初のメッセージが処理されるときに、プロデューサーの作成および起動に若干時間がかかり、合計処理時間が長くなる可能性があることに注意してください。 | false | false | MEDIUM |
| camel.component.aws2-sns.messageDeduplicationId Strategy | FIFO トピックのみ。メッセージに messageDeduplicationId を設定するストラテジー。useExchangeId または useContentBasedDeduplication のいずれかをオプションとして使用できます。useContentBasedDeduplication オプションでは、メッセージに messageDeduplicationId が設定されません。[useExchangeId] または [useContentBasedDeduplication] のいずれか。 | "useExchangeId" | false | MEDIUM |
| camel.component.aws2-sns.messageGroupIdStrategy | FIFO トピックのみ。メッセージに messageGroupId を設定するストラテジー。useConstant、useExchangeId、usePropertyValue のいずれかをオプションとして使用できます。usePropertyValue オプションでは、CamelAwsMessageGroupId プロパティーの値が使用されます。[useConstant]、[useExchangeId]、[usePropertyValue] のいずれか。 | null | false | MEDIUM |
| camel.component.aws2-sns.messageStructure | json などの使用するメッセージ構造。 | null | false | MEDIUM |
| camel.component.aws2-sns.policy | このトピックのポリシー。デフォルトではクラスパスからロードされますが、classpath:、file:、または http: をプレフィックとして指定して、異なるシステムからリソースをロードすることもできます。 | null | false | MEDIUM |
| camel.component.aws2-sns.proxyHost | SNS クライアントをインスタンス化するときにプロキシーホストを定義します。 | null | false | MEDIUM |
| camel.component.aws2-sns.proxyPort | SNS クライアントをインスタンス化するときにプロキシーポートを定義します。 | null | false | MEDIUM |
| camel.component.aws2-sns.proxyProtocol | SNS クライアントをインスタンス化する際にプロキシープロトコルを定義します。[HTTP] または [HTTPS] のいずれか。 | "HTTPS" | false | MEDIUM |
| camel.component.aws2-sns.queueUrl | サブスクライブする queueUrl。 | null | false | MEDIUM |
| camel.component.aws2-sns.region | SNS クライアントが機能する必要があるリージョン。このパラメーターを使用する場合、設定には小文字のリージョン名を指定します (例 ap-east-1)。名前 Region.EU_WEST_1.id() を使用する必要があります。 | null | false | MEDIUM |
| camel.component.aws2-sns.serverSideEncryption Enabled | サーバー側の暗号化がトピックで有効であるかどうかを定義します。 | false | false | MEDIUM |
| camel.component.aws2-sns.subject | メッセージヘッダー 'CamelAwsSnsSubject' が存在しない場合に使用されるサブジェクト。 | null | false | MEDIUM |
| camel.component.aws2-sns.subscribeSNStoSQS | SNS トピックと SQS との間のサブスクリプションを完了する必要があるかどうかを定義します。 | false | false | MEDIUM |
| camel.component.aws2-sns.trustAllCertificates | エンドポイントを上書きするときにすべての証明書を信頼する場合。 | false | false | MEDIUM |
| camel.component.aws2-sns.useDefaultCredentials Provider | SNS クライアントが AWS infra インスタンスでクレデンシャルのロードすること、または静的クレデンシャルが渡されることを SNS クライアントが想定すべきかどうかを設定します。 | false | false | MEDIUM |
| camel.component.aws2-sns.autowiredEnabled | 自動ワイヤリングが有効になっているかどうか。これは、コンポーネントで設定される一致するタイプのインスタンスが 1 つあるかどうかを検出するためにレジストリーを検索することで、自動ワイアリングオプションに使用されます (オプションは自動ワイアとマーク付けされる必要があります)。これは、JDBC データソース、JMS 接続ファクトリー、AWS クライアントなどの自動設定に使用できます。 | true | false | MEDIUM |
| camel.component.aws2-sns.accessKey | Amazon AWS Access Key | null | false | MEDIUM |
| camel.component.aws2-sns.secretKey | Amazon AWS Secret Key | null | false | MEDIUM |
camel-aws2-sns シンクコネクターには、そのまま使えるコンバーターがありません。
camel-aws2-sns シンクコネクターには、そのまま使える transforms がありません。
camel-aws2-sns シンクコネクターにはそのまま使える集約ストラテジーがありません。