[Ultimate]{class="badge positive"}

Azure Event Hubs 接続

概要 overview

Azure Event Hubsはビッグデータ ストリーミング プラットフォームおよびイベント取り込みサービスです。 毎秒数百万件のイベントを受信して処理できます。 イベントハブに送信されたデータは、リアルタイム分析プロバイダーやバッチ/ストレージアダプターを使用して変換および保存できます。

Azure Event Hubs ストレージへのリアルタイムのアウトバウンド接続を作成して、Adobe Experience Platformからデータをストリーミングできます。

ユースケース use-cases

Azure Event Hubsなどのストリーミング宛先を使用すると、価値の高いセグメンテーションイベントと関連するプロファイル属性を、選択したシステムに簡単にフィードできます。

たとえば、見込み客が「コンバージョン傾向が高い」セグメントに分類されるホワイトペーパーをダウンロードしたとします。 見込み客が属するオーディエンスをAzure Event Hubs宛先にマッピングすると、Azure Event Hubsにこのイベントが表示されます。 そこで、日曜大工のアプローチを採用し、イベントの上にビジネスロジックを記述することができます。エンタープライズ IT システムで最も機能すると思うからです。

サポートされるオーディエンス supported-audiences

この節では、この宛先に書き出すことができるオーディエンスのタイプについて説明します。

オーディエンスのデータタイプ別にサポートされるオーディエンス：

書き出しのタイプと頻度 export-type-frequency

宛先の書き出しタイプと頻度については、次の表を参照してください。

IP アドレスの許可リスト ip-address-allowlist

お客様のセキュリティとコンプライアンス要件を満たすために、Experience Platformでは、Azure Event Hubs宛先に対して許可リストに加えるできる静的IPの一覧を提供しています。 許可リストに加えるするIPの完全なリストについては、​ ストリーミング宛先のIP アドレスの許可リストに加えるを参照してください。

宛先への接続 connect

この宛先に接続するには、宛先設定のチュートリアルの手順に従ってください。この宛先に接続する際は、次の情報を指定する必要があります。

認証情報 authentication-information

標準認証 standard-authentication

HTTP エンドポイントに接続する​Standard authentication タイプを選択した場合は、以下のフィールドを入力し、Connect to destination​を選択します。

Shared Access Signature （SAS）認証 sas-authentication

HTTP エンドポイントに接続する​Standard authentication タイプを選択した場合は、以下のフィールドを入力し、Connect to destination​を選択します。

宛先の詳細の入力 destination-details

宛先の詳細を設定するには、以下の必須フィールドとオプションフィールドに入力します。UI のフィールドの横のアスタリスクは、そのフィールドが必須であることを示します。

アラートの有効化 enable-alerts

アラートを有効にすると、宛先へのデータフローのステータスに関する通知を受け取ることができます。リストからアラートを選択して、データフローのステータスに関する通知を受け取るよう登録します。アラートについて詳しくは、UI を使用した宛先アラートの購読についてのガイドを参照してください。

宛先接続の詳細の提供が完了したら、Next​を選択します。

この宛先に対してオーディエンスをアクティブ化 activate

この宛先に対するオーディエンスのアクティブ化の手順については、​ ストリーミングプロファイル書き出し宛先に対するオーディエンスデータのアクティブ化を参照してください。

プロファイルの書き出し動作 profile-export-behavior

Experience Platformは、プロファイルの書き出し動作をAzure Event Hubs宛先に最適化し、オーディエンスの選定やその他の重要なイベントの後にプロファイルに関連する更新が発生した場合にのみ、宛先にデータを書き出します。 プロファイルは、以下の状況で宛先に書き出されます。

上記のすべての場合で、適切な更新が行われたプロファイルのみが宛先に書き出されます。例えば、宛先フローにマッピングされたオーディエンスに 100 人のメンバーがいて、5 つの新しいプロファイルがセグメントに適合している場合、宛先への書き出しは増分で行われ、5 つの新しいプロファイルのみが含まれます。

変更箇所に関わらず、マッピングされたすべての属性がプロファイルに対して書き出されることに注意してください。 したがって、上の例では、属性自体が変更されていない場合でも、これら 5 つの新しいプロファイルに対してマッピングされた属性がすべて書き出されます。

データの書き出しを決定する要素と、書き出しに含まれる内容 what-determines-export-what-is-included

特定のプロファイルに対して書き出されるデータについては、書き出しに含まれるデータがAzure Event Hubs宛先​と​のデータ書き出しを決定するの2つの異なる概念を理解することが重要です。

例えば、このデータフローをAzure Event Hubs宛先に対して考えてみましょう。この宛先では、3つのオーディエンスがデータフローで選択され、4つの属性が宛先にマッピングされます。

宛先へのプロファイルの書き出しは、3 つのマッピングされたセグメント​のいずれかに適合またはいずれかを離脱するプロファイルによって決定されます。データの書き出しでは、segmentMembership オブジェクトに、その特定のプロファイルがそのメンバーであり、書き出しをトリガーしたオーディエンスと同じ結合ポリシーを共有している場合、他のマッピングされたオーディエンスが表示される場合があります（下の書き出されたデータ ​節を参照）。 プロファイルが​Customer with DeLorean Cars セグメントに適格であり、Basic Site ActiveおよびCity - Dallas セグメントのメンバーでもある場合、これらの2つのオーディエンスは、データフローでマッピングされているため、データエクスポートのsegmentMembership オブジェクトにも存在します。これらはDeLorean Cars セグメントを持つ顧客と同じ結合ポリシーを共有する場合です。

プロファイル属性の観点から、上記でマッピングした 4 つの属性に対する変更によって、書き出しの宛先が決定し、プロファイルに存在する 4 つのマッピング済み属性のいずれかがデータ書き出しに表示されます。

履歴データのバックフィル historical-data-backfill

既存の宛先に新しいオーディエンスを追加する場合、または新しい宛先を作成してオーディエンスをマッピングする場合、Experience Platformは過去のオーディエンスの選定データを宛先に書き出します。 オーディエンスが宛先に追加された​ 前 ​のオーディエンスに適格なプロファイルは、約1時間以内に宛先に書き出されます。

書き出したデータ exported-data

書き出された Experience Platform データは、JSON 形式で Azure Event Hubs の宛先に格納されます。例えば、以下の書き出しには、特定のセグメントに適合し、別の 2 つのセグメントのメンバーであり、別のセグメントから離脱したプロファイルが含まれています。 書き出しには、プロファイル属性の名、姓、生年月日、個人メールアドレスも含まれます。 このプロファイルの ID は、ECID とメールです。

{
  "person": {
    "birthDate": "YYYY-MM-DD",
    "name": {
      "firstName": "John",
      "lastName": "Doe"
    }
  },
  "personalEmail": {
    "address": "john.doe@acme.com"
  },
  "segmentMembership": {
   "ups":{
      "7841ba61-23c1-4bb3-a495-00d3g5fe1e93":{
         "lastQualificationTime":"2022-01-11T21:24:39Z",
         "status":"exited"
      },
      "59bd2fkd-3c48-4b18-bf56-4f5c5e6967ae":{
         "lastQualificationTime":"2022-01-02T23:37:33Z",
         "status":"realized"
      },
      "947c1c46-008d-40b0-92ec-3af86eaf41c1":{
         "lastQualificationTime":"2021-08-25T23:37:33Z",
         "status":"realized"
      },
      "5114d758-ce71-43ba-b53e-e2a91d67b67f":{
         "lastQualificationTime":"2022-01-11T23:37:33Z",
         "status":"realized"
      }
   }
},
  "identityMap": {
    "ecid": [
      {
        "id": "14575006536349286404619648085736425115"
      },
      {
        "id": "66478888669296734530114754794777368480"
      }
    ],
    "email_lc_sha256": [
      {
        "id": "655332b5fa2aea4498bf7a290cff017cb4"
      },
      {
        "id": "66baf76ef9de8b42df8903f00e0e3dc0b7"
      }
    ]
  }
}

Include Segment Names​および​Include Segment Timestamps オプションの接続先フローで選択したUI設定に応じて、書き出されたデータの詳細な例を次に示します。

"segmentMembership": {
        "ups": {
          "5b998cb9-9488-4ec3-8d95-fa8338ced490": {
            "lastQualificationTime": "2019-04-15T02:41:50+0000",
            "status": "realized",
            "createdAt": 1648553325000,
            "updatedAt": 1648553330000,
            "mappingCreatedAt": 1649856570000,
            "mappingUpdatedAt": 1649856570000,
            "name": "First name equals John"
          }
        }
      }

"segmentMembership": {
        "ups": {
          "5b998cb9-9488-4ec3-8d95-fa8338ced490": {
            "lastQualificationTime": "2019-04-15T02:41:50+0000",
            "status": "realized",
            "createdAt": 1648553325000,
            "updatedAt": 1648553330000,
            "mappingCreatedAt": 1649856570000,
            "mappingUpdatedAt": 1649856570000,
          }
        }
      }

制限と再試行ポリシー limits-retry-policy

Experience Platform は 95％ の確率で、HTTP 宛先の各データフローにおいて、送信に成功したメッセージのスループット待ち時間を 10 分未満、リクエスト数を 1 秒あたり 10,000 件未満で提供しようと試みます。

HTTP API 宛先へのリクエストが失敗した場合、Experience Platform は失敗したリクエストを保存し、リクエストをエンドポイントに送信するために 2 回再試行します。