AWS Kinesis Streams コネクタ構成ガイド
この記事では、AWS Kinesis Streams コネクタの構成方法について説明します。
必要条件
- Amazon Web Services アカウント
- Identity and Access Management (IAM) ユーザー認証情報
- Kinesis Streams
コネクタのアクション
アクション名 | AudienceStream | EventStream |
---|---|---|
Kinesis Stream へのイベントデータ送信 | ✗ | ✓ |
Kinesis Stream への訪問データ送信 | ✓ | ✗ |
Kinesis Stream へのカスタマイズデータ送信(上級) | ✓ | ✓ |
Kinesis Stream へのバッチイベントデータ送信 | ✗ | ✓ |
Kinesis Stream へのバッチ訪問データ送信 | ✓ | ✗ |
Kinesis Stream へのバッチカスタマイズデータ送信(上級) | ✓ | ✓ |
構成の構成
コネクタマーケットプレイスに移動して、新しいコネクタを追加します。コネクタの追加方法については、コネクタについてを参照してください。
コネクタを追加した後、以下の構成を構成します:
- アクセスキー
必須:IAM ユーザーのアクセスキーを提供してください。関連するIAMポリシー(IAMユーザーまたは仮定されたロール用)は、データを送信したいストリームに対してkinesis:PutRecord
権限を付与する必要があります。参照:Kinesis Streams リソースアクセス。 - シークレットキー
必須:IAM ユーザーのシークレットキーを提供してください。 - リージョン
必須:リージョンを選択してください。 - ロールの引き受け:ARN
オプション:引き受けるロールの Amazon Resource Name (ARN) を提供してください。例:arn:aws:iam::222222222222:role/myrole
。参照:IAM ロールへの切り替え。 - ロールの引き受け:セッション名
オプション:引き受けたロールセッションの識別子を提供してください。 - ロールの引き受け:外部ID
オプション:外部識別子を提供してください。参照:外部IDの使用方法。
アクション
アクションの名前を入力し、ドロップダウンメニューからアクションタイプを選択します。
次のセクションでは、各アクションのパラメータとオプションの構成方法について説明します。
アクション構成 - Kinesis Stream へのイベントデータ送信
パラメータ
パラメータ | 説明 |
---|---|
ストリーム名 | データを送信するストリームを選択します。IAMポリシーが kinesis:ListStreams 権限を付与していない場合は、カスタム値を手動で入力する必要があります。 |
パーティションキー | (必須) パーティションキーは、ストリーム内のシャードにデータをグループ化します。 |
シーケンス番号(順序付け用) | Kinesisデータストリームのシャード内のデータレコードのシーケンス番号。 |
明示的ハッシュキー | パーティションキーをハッシュするために使用されるキー。 |
属性名の印刷 | 属性名が更新された場合、ペイロード内の名前が更新を反映します。 |
アクション構成 - Kinesis Stream への訪問データ送信
パラメータ
パラメータ | 説明 |
---|---|
ストリーム名 | データを送信するストリームを選択します。IAMポリシーが kinesis:ListStreams 権限を付与していない場合は、カスタム値を手動で入力する必要があります。 |
パーティションキー | (必須) パーティションキーは、ストリーム内のシャードにデータをグループ化します。 |
シーケンス番号(順序付け用) | Kinesisデータストリームのシャード内のデータレコードのシーケンス番号。 |
明示的ハッシュキー | パーティションキーをハッシュするために使用されるキー。 |
訪問データを訪問データに含める | 現在の訪問データをペイロードに追加します。これには、現在の訪問イベントデータが除外されていない場合のイベント訪問データが含まれます。 |
現在の訪問イベントデータを除外 | 現在の訪問データからイベントデータを除外します。 |
属性名の印刷 | 属性名が更新された場合、ペイロード内の名前が更新を反映します。 |
アクション構成 - Kinesis Stream へのカスタマイズデータ送信(上級)
パラメータ
パラメータ | 説明 |
---|---|
ストリーム名 | データを送信するストリームを選択します。IAMポリシーが ‘kinesis:ListStreams’ 権限を付与していない場合は、カスタム値を手動で入力する必要があります。 |
パーティションキー | (必須) パーティションキーは、ストリーム内のシャードにデータをグループ化します。 |
シーケンス番号(順序付け用) | Kinesisデータストリームのシャード内のデータレコードのシーケンス番号。 |
明示的ハッシュキー | パーティションキーをハッシュするために使用されるキー。 |
カスタムメッセージ定義 | ログファイルに含めるカスタムメッセージ。 |
テンプレート変数 | オプション。
|
テンプレート | オプション。
|
アクション構成 - Kinesis Stream へのバッチイベントデータ送信
バッチ制限
このアクションは、ベンダーへの大量データ転送をサポートするためにバッチリクエストを使用します。詳細については、バッチアクションを参照してください。リクエストは、次のいずれかの閾値が達成されるか、プロファイルが公開されるまでキューに入れられます:
- 最大リクエスト数:500
- 最古のリクエストからの最大時間:10分
- リクエストの最大サイズ:5 MB
パラメータ
パラメータ | 説明 |
---|---|
ストリーム名 | データを送信するストリームを選択します。IAMポリシーが kinesis:ListStreams 権限を付与していない場合は、カスタム値を手動で入力する必要があります。 |
パーティションキー | (必須) パーティションキーは、ストリーム内のシャードにデータをグループ化します。 |
明示的ハッシュキー | パーティションキーをハッシュするために使用されるキー。 |
属性名の印刷 | 属性名が更新された場合、ペイロード内の名前が更新を反映します。 |
アクション構成 - Kinesis Stream へのバッチ訪問データ送信
バッチ制限
このアクションは、ベンダーへの大量データ転送をサポートするためにバッチリクエストを使用します。詳細については、バッチアクションを参照してください。リクエストは、次のいずれかの閾値が達成されるか、プロファイルが公開されるまでキューに入れられます:
- 最大リクエスト数:500
- 最古のリクエストからの最大時間:10分
- リクエストの最大サイズ:5 MB
パラメータ
パラメータ | 説明 |
---|---|
ストリーム名 | データを送信するストリームを選択します。IAMポリシーが ‘kinesis:ListStreams’ 権限を付与していない場合は、カスタム値を手動で入力する必要があります。 |
パーティションキー | (必須) パーティションキーは、ストリーム内のシャードにデータをグループ化します。 |
明示的ハッシュキー | パーティションキーをハッシュするために使用されるキー。 |
現在の訪問データを含める | ペイロードに現在の訪問データを含めるかどうかを示す true /false 値。 |
属性名の印刷 | 属性名が更新された場合、ペイロード内の名前が更新を反映します。 |
アクション構成 - Kinesis Stream へのバッチカスタマイズデータ送信(上級)
バッチ制限
このアクションは、ベンダーへの大量データ転送をサポートするためにバッチリクエストを使用します。詳細については、バッチアクションを参照してください。リクエストは、次のいずれかの閾値が達成されるか、プロファイルが公開されるまでキューに入れられます:
- 最大リクエスト数:500
- 最古のリクエストからの最大時間:10分
- リクエストの最大サイズ:5 MB
パラメータ
パラメータ | 説明 |
---|---|
ストリーム名 | データを送信するストリームを選択します。IAMポリシーが kinesis:ListStreams 権限を付与していない場合、カスタム値を手動で入力する必要があります。 |
パーティションキー | (必須)パーティションキーは、ストリーム内のシャードにデータをグループ化します。 |
明示的ハッシュキー | パーティションキーをハッシュするために使用されるキーです。 |
カスタムメッセージ定義 | ログファイルに含めるカスタムメッセージです。 |
テンプレート変数 | 任意。
|
テンプレート | 任意。
|
最終更新日 :: 2025年June月13日