ストリーム問合せ構文

概要

ストリーム・ラボおよびアクション・センターでは、ストリーム問合せを使用して、特定のニーズに合わせてストリームを調整できます。ストリーム問合せは、ストリームに含めるデータやデータを照合する必要がある条件などを指定できる点で、SQLと似ています。ストリーム問合せの詳細を示すリファレンスと、これらの問合せによって強力なアナリティクスとデータ・パイプラインを活用できるようにするユース・ケースを次に示します。

問合せ形式:

ストリーム問合せは、次の形式で構成されます。

SELECT <select criteria> WHERE <where criteria> HAVING <having criteria>

Select条件 - 必須

select条件は、メッセージに含める値のカンマ区切りのリストです。

別名 - オプション

select条件では、 <selection> AS '<alias>'という形式のオプションの別名を受け入れることができます。

<selection>には、ワイルドカードを使用しない、前述の表の任意の条件を指定でき、<alias>には任意の文字列を指定できます

たとえば:

SELECT session.visitor_id AS 'visitor.id', session.session_id as 'visitor.session', EARLIEST(data.wt.cg_n) AS 'content.group.first', LATEST(data.wt.cg_n) AS 'content.group.last'

次のメッセージが生成されます。

{
  "meta": {
    "schema_version": "3.0",
    "api_version": "3.0",
    "message_type": "session_update",
    "stream_type": "session_all"
  },
  "content": {
    "group": {
      "first": [
        "Shop Maxymised"
      ],
      "last": [
        "Cart"
      ]
    }
  },
  "visitor": {
    "id": "1348447491483863571",
    "session": "1532364415416010076"
  }
}

Where条件 - オプション

WHERE条件では、ストリーム・メッセージが生成されるかどうか、またいつ生成されるかを定義します。イベントがセッションに追加されると、この条件と比較され、trueと評価された場合は更新メッセージが生成されます。

WHERE句が指定されていない場合、セッションにイベントが追加されるたびに更新メッセージが生成され、セッションがクローズされたときにクローズ・メッセージも生成されます。

現在処理中のイベントのみでなく、セッション内のすべてのイベントを評価する場合は、ALLおよびANY演算子を使用します。

ノート: 別名およびSelect条件はメッセージの送信時にのみ使用され、問合せ内のWHERE (またはHAVING)句では使用できません。

たとえば、次の構文はサポートされません。

• Select data.wt.ti as 'A' where 'A" = 'B'
• Select * where earliest(data.wt.ti) = 'B'
• Select count(data.wt.ti) where count(data.wt.ti) >= 1
• Select event_count() where event_count() >= 1

Having条件 - オプション

HAVING句では、セッション・レベルのデータを問い合せるときに、セッション内のどのイベントを含めるかを定義します。

HAVING句では、どのイベントをメッセージに含める必要があるかが決定され、一方WHERE句では、メッセージを送信する必要があるかどうかが決定されるという点で、HAVING句はWHERE句と異なります。

HAVING句は、次に示すセッション・レベル・セレクタを使用した選択にのみ適用されることに注意してください。

たとえば、次のようなselect文があるとします。

SELECT data.wt.ti AS 'current_page_title', CONCAT_DISTINCT(data.wt.ti, ',') AS 'all_phone_page_titles' HAVING data.wt.ti like '*phones*'

WHERE句がないため、すべてのイベントでメッセージが送信されます。

data.wt.tiの値は、HAVING句と一致するかどうかにかかわらず、存在する場合はすべてのイベントでcurrent_page_titleとして送信されます。これは、この文でセッション・レベル・セレクタが使用されていないためです。

all_phone_page_titlesにはCONCAT_DISTINCTのセッション・レベル・セレクタが使用されているため、すべてのイベントからのHAVING句に一致するすべての個別値もすべてのメッセージに含められます。

たとえば:

{
  "meta": {
    "schema_version": "3.0",
    "api_version": "3.0",
    "message_type": "session_update",
    "stream_type": "session_all"
  },
  "all_phone_page_titles": "Google Phones,Samsung Phones",
  "current_page_title": "SLR Cameras"
}

HAVING句が指定されていない場合、セッション・レベルのデータを選択すると、セッション内のすべてのイベントが含められます。

HAVINGの演算子は基本的にはWHEREと同じですが、HAVING句ではALLおよびANYを使用できません。また、WHERE句と同様に、別名およびSelect条件はサポートされません。

[該当する場合はキーワードを追加します。キーワードはFlareのSEOのために使用されるもので、出力には表示されません。キーワードはカンマで区切ります。例: キャンペーン, キャンペーン設定, キャンペーンの設定]