Elasticコネクタ構成ガイド
この記事では、Elasticコネクタの構成方法について説明します。
構成
コネクタマーケットプレイスにアクセスし、新しいコネクタを追加します。コネクタを追加する一般的な手順については、コネクタについてを参照してください。
コネクタを追加した後、以下の構成を構成します:
- 認証タイプ:認証タイプを選択します。
- ホスト:(必須)ElasticホストURL。
- APIキー:(必須)Elastic APIキー。
データストリームの作成
データストリームを作成するには:
- リモート構成の下でデータストリームの作成をクリックします。
- データストリーム名を入力します。
- データストリームの作成 & 閉じるをクリックします。
アクション
| アクション名 | AudienceStream | EventStream |
|---|---|---|
| 全イベントデータの送信 | ✗ | ✓ |
| 全イベントデータの送信(バッチ) | ✗ | ✓ |
| カスタムイベントデータの送信 | ✗ | ✓ |
| カスタムイベントデータの送信(バッチ) | ✗ | ✓ |
| 全ログイベントの送信 | ✗ | ✓ |
| ログイベントの送信 | ✗ | ✓ |
| 全訪問データの送信 | ✓ | ✗ |
| 全訪問データの送信(バッチ) | ✓ | ✗ |
| カスタム訪問データの送信 | ✓ | ✗ |
| カスタム訪問データの送信(バッチ) | ✓ | ✗ |
全イベントデータの送信
パラメータ
| パラメータ | 説明 |
|---|---|
| ターゲットタイプ | (必須)ターゲットタイプを指定します:インデックスまたはデータストリーム。 |
| ターゲット | (必須)ターゲットを指定します。ターゲットタイプがインデックスの場合、カスタム値が受け入れられます(必要に応じてインデックスがその場で作成されます)。ターゲットタイプがデータストリームの場合、既存のデータストリームを選択するか、データストリームの作成をクリックして新しいものを作成します。データストリーム名を入力し、データストリームの作成 & 閉じるをクリックします。 |
ドキュメントの詳細
オプションのドキュメントメタデータ。利用可能なキーはターゲットタイプに依存します。
| パラメータ | 説明 |
|---|---|
document_id |
ユニークなドキュメント識別子。ターゲットタイプがインデックスの場合に利用可能です。 |
timestamp |
イベントタイムスタンプはISO 8601形式(例:2025-05-16T11:48:00Z)またはエポックナノ秒(例:1715856480000000000)。ターゲットタイプがデータストリームの場合に利用可能です。空白または形式が不正な場合は現在の時間がデフォルトです。 |
並行制御
| パラメータ | 説明 |
|---|---|
primary_term |
ドキュメントがこのプライマリタームを持つ場合にのみ操作を実行します。 |
seq_no |
ドキュメントがこのシーケンス番号を持つ場合にのみ操作を実行します。 |
version |
並行制御のための明示的なバージョン番号。非負の長整数でなければなりません。 |
| エラー処理 | Elasticが解析エラーを報告する方法を構成します。 |
並行制御パラメータはデータストリームには対応していません。データストリームは追加専用であり、最初に書き込まれたものが優先されるため、primary_term、seq_no、およびversionは効果がありません。楽観的な並行制御またはドキュメントの更新が必要な場合は、データストリームではなく通常のインデックスまたはその書き込みエイリアスを対象としてください。
インデックス動作
ドキュメントがインデックスされる方法を制御するオプショナルパラメータ。
| パラメータ | 説明 |
|---|---|
operation_type |
ドキュメントのインデックス方法を定義します。indexは同じIDの既存のドキュメントを上書きします。createは挿入のみを行い、同じIDのドキュメントが既に存在する場合は失敗します。ターゲットタイプがインデックスの場合のみ利用可能です。 |
pipeline |
ドキュメントを事前処理するために使用されるインジェストパイプラインのID。デフォルトのインジェストパイプラインを無効にするには、_noneを使用します。 |
routing |
特定のシャードに操作を指示するカスタムルーティング値。 |
wait_for_active_shards |
進行する前に必要な最小シャードコピー数。デフォルト:1。許可される値:allまたはシャードの総数(number_of_replicas + 1)までの任意の正の整数。 |
| Refresh | インデックス操作が検索で表示されるタイミングを決定します。許可される値:true、false、wait_for。 |
| イベントデータ | イベントペイロードキーがどのように発行されるかを構成します。 |
| カスタム属性 | JSONオブジェクトのルートレベルに追加したい任意の追加属性を含めます。 |
全イベントデータの送信(バッチ)
バッチ制限
このアクションは、ベンダーへの大量データ転送をサポートするためにバッチリクエストを使用します。並行処理により、イベントがベンダーに順不同で到達する可能性があります。順序が重要な場合は、イベントにシーケンス値を追加します。詳細については、バッチアクションを参照してください。次のいずれかの閾値に達するか、プロファイルが公開されるまでリクエストがキューに入れられます:
- 最大リクエスト数:300,000
- 最古のリクエストからの最大時間:60分
- リクエストの最大サイズ:100 MB
パラメータ
| パラメータ | 説明 |
|---|---|
| ターゲットタイプ | (必須)ターゲットタイプを指定します:インデックスまたはデータストリーム。 |
| ターゲット | (必須)ターゲットを指定します。ターゲットタイプがインデックスの場合、カスタム値が受け入れられます(必要に応じてインデックスがその場で作成されます)。ターゲットタイプがデータストリームの場合、既存のデータストリームを選択するか、データストリームの作成をクリックして新しいものを作成します。データストリーム名を入力し、データストリームの作成 & 閉じるをクリックします。 |
ドキュメントの詳細
オプションのドキュメントメタデータ。利用可能なキーはターゲットタイプに依存します。
| パラメータ | 説明 |
|---|---|
document_id |
ユニークなドキュメント識別子。ターゲットタイプがインデックスの場合に利用可能です。 |
timestamp |
イベントタイムスタンプはISO 8601形式(例:2025-05-16T11:48:00Z)またはエポックナノ秒(例:1715856480000000000)。ターゲットタイプがデータストリームの場合に利用可能です。空白または形式が不正な場合は現在の時間がデフォルトです。 |
並行制御
| パラメータ | 説明 |
|---|---|
primary_term |
ドキュメントがこのプライマリタームを持つ場合にのみ操作を実行します。 |
seq_no |
ドキュメントがこのシーケンス番号を持つ場合にのみ操作を実行します。 |
version |
並行制御のための明示的なバージョン番号。非負の長整数でなければなりません。 |
| エラー処理 | Elasticが解析エラーを報告する方法を構成します。 |
並行制御パラメータはデータストリームには対応していません。データストリームは追加専用であり、最初に書き込まれたものが優先されるため、primary_term、seq_no、およびversionは効果がありません。楽観的な並行制御またはドキュメントの更新が必要な場合は、データストリームではなく通常のインデックスまたはその書き込みエイリアスを対象としてください。
インデックス動作
ドキュメントがインデックスされる方法を制御するオプショナルパラメータ。
| パラメータ | 説明 |
|---|---|
operation_type |
ドキュメントのインデックス方法を定義します。indexは同じIDの既存のドキュメントを上書きします。createは挿入のみを行い、同じIDのドキュメントが既に存在する場合は失敗します。ターゲットタイプがインデックスの場合のみ利用可能です。 |
pipeline |
ドキュメントを事前処理するために使用されるインジェストパイプラインのID。デフォルトのインジェストパイプラインを無効にするには、_noneを使用します。 |
routing |
特定のシャードに操作を指示するカスタムルーティング値。 |
wait_for_active_shards |
進行する前に必要な最小シャードコピー数。デフォルト:1。許可される値:allまたはシャードの総数(number_of_replicas + 1)までの任意の正の整数。 |
| Refresh | インデックス操作が検索で表示されるタイミングを決定します。許可される値:true、false、wait_for。 |
| イベントデータ | イベントペイロードキーがどのように発行されるかを構成します。 |
| カスタム属性 | JSONオブジェクトのルートレベルに追加したい任意の追加属性を含めます。 |
| バッチの有効期限 | バッチの有効期限(分)。許可される値:1から60。デフォルト:60。 |
カスタムイベントデータの送信
パラメータ
| パラメータ | 説明 |
|---|---|
| ターゲットタイプ | (必須)ターゲットタイプを指定します:インデックスまたはデータストリーム。 |
| ターゲット | (必須)ターゲットを指定します。ターゲットタイプがインデックスの場合、カスタム値が受け入れられます(必要に応じてインデックスがその場で作成されます)。ターゲットタイプがデータストリームの場合、既存のデータストリームを選択するか、データストリームの作成をクリックして新しいものを作成します。データストリーム名を入力し、データストリームの作成 & 閉じるをクリックします。 |
ドキュメントの詳細
オプショナルなドキュメントメタデータ。利用可能なキーはターゲットタイプによって異なります。
| パラメータ | 説明 |
|---|---|
document_id |
ユニークなドキュメント識別子。ターゲットタイプがインデックスの場合に利用可能。 |
timestamp |
イベントのタイムスタンプ(例:2025-05-16T11:48:00Z)またはエポックナノ秒(例:1715856480000000000)。ターゲットタイプがデータストリームの場合に利用可能。空白または形式が不正な場合は現在の時間がデフォルト。 |
並行制御
| パラメータ | 説明 |
|---|---|
primary_term |
ドキュメントがこのプライマリタームを持つ場合のみ操作を実行します。 |
seq_no |
ドキュメントがこのシーケンス番号を持つ場合のみ操作を実行します。 |
version |
並行制御のための明示的なバージョン番号。非負の長整数でなければなりません。 |
| エラー処理 | Elasticがパースエラーを報告する方法を構成します。 |
並行制御パラメータはデータストリームではサポートされていません。データストリームは追記のみ可能で、最初に書き込まれたものが優先されるため、primary_term、seq_no、versionは効果がありません。楽観的な並行制御やドキュメントの更新が必要な場合は、データストリームではなく通常のインデックスまたはその書き込みエイリアスを対象にしてください。
インデクシングの挙動
ドキュメントがどのようにインデックスされるかを制御するオプショナルなパラメータ。
| パラメータ | 説明 |
|---|---|
operation_type |
ドキュメントのインデクシング方法を定義します。indexは同じIDの既存のドキュメントを上書きします。createは新規挿入のみを行い、同じIDのドキュメントが既に存在する場合は失敗します。ターゲットタイプがインデックスの場合のみ利用可能。 |
pipeline |
ドキュメントの前処理に使用するインジェストパイプラインのID。デフォルトのインジェストパイプラインを無効にするには _none を使用します。 |
routing |
操作を特定のシャードに向けるためのカスタムルーティング値。 |
wait_for_active_shards |
処理を進める前に必要な最小シャードコピー数。デフォルト:1。許可される値:allまたはシャードの総数(number_of_replicas + 1)までの任意の正の整数。 |
| リフレッシュ | インデクシング操作が検索で表示されるタイミングを決定します。許可される値:true、false、wait_for。 |
| カスタム属性 | JSONオブジェクトのルートレベルに追加したい任意の追加属性を含めます。 |
カスタムイベントデータの送信(バッチ)
バッチ制限
このアクションはバッチリクエストを使用して、ベンダーへの大量データ転送をサポートします。並行処理により、イベントがベンダーに順不同で到達する可能性があります。順序が重要な場合は、イベントにシーケンス値を追加してください。詳細については、バッチアクションを参照してください。リクエストは、次のいずれかの閾値に達するか、プロファイルが公開されるまでキューに入れられます:
- 最大リクエスト数:300,000
- 最古のリクエストからの最大時間:60分
- リクエストの最大サイズ:100 MB
パラメータ
| パラメータ | 説明 |
|---|---|
| ターゲットタイプ | (必須) ターゲットタイプを指定します:インデックスまたはデータストリーム。 |
| ターゲット | (必須) ターゲットを指定します。ターゲットタイプがインデックスの場合、カスタム値が受け入れられます(必要に応じてインデックスがその場で作成されます)。ターゲットタイプがデータストリームの場合、既存のデータストリームを選択するか、データストリームの作成をクリックして新しいものを作成します。データストリーム名を入力し、データストリームの作成 & 閉じるをクリックします。 |
インデックス動作
ドキュメントがインデックスされる方法を制御するオプションのパラメーター。
| パラメーター | 説明 |
|---|---|
operation_type |
ドキュメントのインデックス方法を定義します。indexは同じIDを持つ既存のドキュメントを上書きします。createは新規挿入のみを行い、同じIDを持つドキュメントが既に存在する場合は失敗します。対象タイプがインデックスの場合のみ利用可能です。 |
pipeline |
ドキュメントの前処理に使用されるインジェストパイプラインのID。デフォルトのインジェストパイプラインを無効にするには _none を使用します。 |
routing |
特定のシャードに操作を指示するカスタムルーティング値。 |
wait_for_active_shards |
進行する前に必要な最小シャードコピー数。デフォルト:1。許可される値:allまたはシャードの総数までの任意の正の整数(number_of_replicas + 1)。 |
| Refresh | インデックス操作が検索で表示されるタイミングを決定します。許可される値:true, false, wait_for。 |
| カスタム属性 | JSONオブジェクトのルートレベルに追加したい任意の追加属性を含めます。 |
ログイベントの送信
パラメーター
| パラメーター | 説明 |
|---|---|
| 対象タイプ | (必須)対象タイプを指定します:インデックスまたはデータストリーム。 |
| 対象 | (必須)対象を指定します。対象タイプがインデックスの場合、カスタム値が受け入れられます(必要に応じてインデックスが動的に作成されます)。対象タイプがデータストリームの場合、既存のデータストリームを選択するか、データストリームの作成をクリックして新しいものを作成します。データストリーム名を入力し、データストリームの作成&クローズをクリックします。 |
ドキュメントの詳細
対象タイプに依存するオプションのドキュメントメタデータ。利用可能なキーは対象タイプによります。
| パラメーター | 説明 |
|---|---|
document_id |
ユニークなドキュメント識別子。対象タイプがインデックスの場合に利用可能です。 |
timestamp |
イベントのタイムスタンプ(例:2025-05-16T11:48:00Z)またはエポックナノ秒(例:1715856480000000000)。対象タイプがデータストリームの場合に利用可能です。空白または形式が不正な場合は現在の時間がデフォルトとして使用されます。 |
並行制御
| パラメーター | 説明 |
|---|---|
primary_term |
ドキュメントがこのプライマリタームを持つ場合にのみ操作を実行します。 |
seq_no |
ドキュメントがこのシーケンス番号を持つ場合にのみ操作を実行します。 |
version |
並行制御のための明示的なバージョン番号。非負の長整数でなければなりません。 |
| エラー処理 | Elasticがパースエラーを報告する方法を構成します。 |
並行制御パラメーターはデータストリームではサポートされていません。データストリームは追記のみ可能で、最初に書き込まれたものが優先されるセマンティクスを強制しますので、primary_term、seq_no、およびversionは効果がありません。楽観的な並行制御またはドキュメントの更新が必要な場合は、通常のインデックスまたはその書き込みエイリアスを対象にしてください。
パラメータ
| パラメータ | 説明 |
|---|---|
| ターゲットタイプ | (必須) ターゲットタイプを指定します: インデックスまたはデータストリーム。 |
| ターゲット | (必須) ターゲットを指定します。ターゲットタイプがインデックスの場合、カスタム値が受け入れられます(必要に応じてインデックスが動的に作成されます)。ターゲットタイプがデータストリームの場合、既存のデータストリームを選択するか、データストリームの作成をクリックして新しいものを作成します。データストリーム名を入力し、データストリームの作成 & 閉じるをクリックします。 |
ドキュメントの詳細
オプショナルなドキュメントメタデータ。利用可能なキーはターゲットタイプに依存します。
| パラメータ | 説明 |
|---|---|
document_id |
ユニークなドキュメント識別子。ターゲットタイプがインデックスの場合に利用可能。 |
timestamp |
イベントのタイムスタンプ(例: 2025-05-16T11:48:00Z)またはエポックナノ秒(例: 1715856480000000000)。ターゲットタイプがデータストリームの場合に利用可能。空白または形式が不正な場合は現在時刻がデフォルト値となります。 |
並行制御
| パラメータ | 説明 |
|---|---|
primary_term |
ドキュメントがこのプライマリタームを持つ場合のみ操作を実行します。 |
seq_no |
ドキュメントがこのシーケンス番号を持つ場合のみ操作を実行します。 |
version |
明示的なバージョン番号での並行制御。非負の長整数でなければなりません。 |
| エラー処理 | Elasticがパースエラーを報告する方法を構成します。 |
並行制御パラメータはデータストリームではサポートされていません。データストリームは追記のみ可能で、最初に書き込まれたものが優先されるセマンティクスを強制しますので、primary_term、seq_no、versionは効果がありません。楽観的な並行制御やドキュメントの更新が必要な場合は、データストリームではなく通常のインデックスまたはその書き込みエイリアスを対象にしてください。
インデックス動作
ドキュメントがどのようにインデックスされるかを制御するオプショナルなパラメータ。
| パラメータ | 説明 |
|---|---|
operation_type |
ドキュメントのインデックス方法を定義します。indexは同じIDの既存のドキュメントを上書きします。createは挿入のみを行い、同じIDのドキュメントが既に存在する場合は失敗します。ターゲットタイプがインデックスの場合のみ利用可能。 |
pipeline |
ドキュメントの前処理に使用するインジェストパイプラインのID。デフォルトのインジェストパイプラインを無効にするには _none を使用します。 |
routing |
操作を特定のシャードに向けるためのカスタムルーティング値。 |
wait_for_active_shards |
処理を進める前に必要な最小シャードコピー数。デフォルト: 1。許可される値: all またはシャードの総数 (number_of_replicas + 1) までの任意の正の整数。 |
| Refresh | インデックス操作が検索で表示されるタイミングを決定します。許可される値: true, false, wait_for。 |
| イベントデータ | イベントペイロードキーの出力方法を構成します。 |
| カスタム属性 | JSONオブジェクトのルートレベルに追加したい任意の追加属性を含めます。 |
カスタム訪問データの送信
パラメータ
| パラメータ | 説明 |
|---|---|
| ターゲットタイプ | (必須) ターゲットタイプを指定します: インデックスまたはデータストリーム。 |
| ターゲット | (必須) ターゲットを指定します。ターゲットタイプがインデックスの場合、カスタム値が受け入れられます(必要に応じてインデックスが動的に作成されます)。ターゲットタイプがデータストリームの場合、既存のデータストリームを選択するか、データストリームの作成をクリックして新しいものを作成します。データストリーム名を入力し、データストリームの作成 & 閉じるをクリックします。 |
ドキュメントの詳細
オプショナルなドキュメントメタデータ。利用可能なキーはターゲットタイプに依存します。
| パラメータ | 説明 |
|---|---|
document_id |
ユニークなドキュメント識別子。ターゲットタイプがインデックスの場合に利用可能。 |
timestamp |
イベントのタイムスタンプ(例: 2025-05-16T11:48:00Z)またはエポックナノ秒(例: 1715856480000000000)。ターゲットタイプがデータストリームの場合に利用可能。空白または形式が不正な場合は現在時刻がデフォルト値となります。 |
| メッセージ属性 | JSONオブジェクト内のmessage属性にカスタム属性をマッピングします。ドキュメントのルートに値を渡すには、代わりにカスタム属性を使用します。 |
並行制御
| パラメータ | 説明 |
|---|---|
primary_term |
ドキュメントがこのプライマリタームを持つ場合のみ操作を実行します。 |
seq_no |
ドキュメントがこのシーケンス番号を持つ場合のみ操作を実行します。 |
version |
明示的なバージョン番号での並行制御。非負の長整数でなければなりません。 |
| エラー処理 | Elasticがパースエラーを報告する方法を構成します。 |
並行制御パラメータはデータストリームではサポートされていません。データストリームは追記のみ可能で、最初に書き込まれたものが優先されるセマンティクスを強制しますので、primary_term、seq_no、versionは効果がありません。楽観的な並行制御やドキュメントの更新が必要な場合は、データストリームではなく通常のインデックスまたはその書き込みエイリアスを対象にしてください。
インデックス動作
ドキュメントがどのようにインデックスされるかを制御するオプショナルなパラメータ。
| パラメータ | 説明 |
|---|---|
operation_type |
ドキュメントのインデックス方法を定義します。indexは同じIDの既存のドキュメントを上書きします。createは挿入のみを行い、同じIDのドキュメントが既に存在する場合は失敗します。ターゲットタイプがインデックスの場合のみ利用可能。 |
pipeline |
ドキュメントの前処理に使用するインジェストパイプラインのID。デフォルトのインジェストパイプラインを無効にするには _none を使用します。 |
routing |
操作を特定のシャードに向けるためのカスタムルーティング値。 |
wait_for_active_shards |
処理を進める前に必要な最小シャードコピー数。デフォルト: 1。許可される値: all またはシャードの総数 (number_of_replicas + 1) までの任意の正の整数。 |
| Refresh | インデックス操作が検索で表示されるタイミングを決定します。許可される値: true, false, wait_for。 |
| カスタム属性 | JSONオブジェクトのルートレベルに追加したい任意の追加属性を含めます。 |
カスタム訪問データの一括送信
一括制限
このアクションは、ベンダーへの大量データ転送をサポートするために一括リクエストを使用します。並行処理により、イベントがベンダーに順不同で到達する可能性があります。順序が重要な場合は、イベントにシーケンス値を追加してください。詳細については、一括アクションを参照してください。リクエストは、次のいずれかのしきい値に達するか、プロファイルが公開されるまでキューに入れられます:
- 最大リクエスト数: 300,000
- 最古のリクエストからの最大時間: 60分
- リクエストの最大サイズ: 100 MB
パラメータ
| パラメータ | 説明 |
|---|---|
| ターゲットタイプ | (必須) ターゲットタイプを指定します: インデックスまたはデータストリーム。 |
| ターゲット | (必須) ターゲットを指定します。ターゲットタイプがインデックスの場合、カスタム値が受け入れられます(必要に応じてインデックスが動的に作成されます)。ターゲットタイプがデータストリームの場合、既存のデータストリームを選択するか、データストリームの作成をクリックして新しいものを作成します。データストリーム名を入力し、データストリームの作成 & 閉じるをクリックします。 |
ドキュメントの詳細
オプショナルなドキュメントメタデータ。利用可能なキーはターゲットタイプに依存します。
| パラメータ | 説明 |
|---|---|
document_id |
ユニークなドキュメント識別子。ターゲットタイプがインデックスの場合に利用可能。 |
timestamp |
イベントのタイムスタンプ(例: 2025-05-16T11:48:00Z)またはエポックナノ秒(例: 1715856480000000000)。ターゲットタイプがデータストリームの場合に利用可能。空白または形式が不正な場合は現在時刻がデフォルト値となります。 |
| メッセージ属性 | JSONオブジェクト内のmessage属性にカスタム属性をマッピングします。ドキュメントのルートに値を渡すには、代わりにカスタム属性を使用します。 |
| エラー処理 | Elasticがパースエラーを報告する方法を構成します。 |
インデックスの挙動
ドキュメントがインデックスされる際のオプショナルパラメーター。
| パラメーター | 説明 |
|---|---|
operation_type |
ドキュメントのインデックス方法を定義します。indexは同じIDを持つ既存のドキュメントを上書きします。createは新規挿入のみを行い、同じIDを持つドキュメントが既に存在する場合は失敗します。対象タイプがインデックスの場合のみ利用可能です。 |
pipeline |
ドキュメントの前処理に使用されるインジェストパイプラインのID。デフォルトのインジェストパイプラインを無効にするには _none を使用します。 |
routing |
特定のシャードへの操作を指示するカスタムルーティング値。 |
wait_for_active_shards |
進行する前に必要な最小シャードコピー数。デフォルト:1。許可される値:allまたはシャードの総数(number_of_replicas + 1)までの任意の正の整数。 |
| Refresh | インデックス操作が検索で表示されるタイミングを決定します。許可される値:true, false, wait_for。 |
| カスタム属性 | JSONオブジェクトのルートレベルに追加したい任意の追加属性を含めます。 |
| バッチの有効期限 | バッチの有効期限(分)。許可される値:1から60。デフォルト:60。 |
最終更新日 :: 2026年June月10日