Skip to content
Last updated

Firebase Cloud Messaging Export Integration

Firebaseは、より豊かなアプリ体験を提供するのに役立つモバイルおよびWebアプリケーション開発プラットフォームです。Firebase Cloud Messagingを通じて、モバイルアプリやWebサイトに直接通知を送信できます。

Realtime DatabaseとCloud Firestoreは、ドキュメント構造のデータを保存し、データ変換が発生するたびに対応するアプリをミリ秒単位で同期できます。アプリとデータベースは相互にリッスンし合い、顧客により反応性の高いアプリ体験を提供します。Firebase Cloud Functionsを使用すると、サーバーを管理することなく、Firebaseプラットフォームで発生するイベントに応答するバックエンドコードを記述できます。

前提条件

  • TD Toolbeltを含むTreasure Dataの基礎知識。
  • Google Firebaseプロジェクト。
  • 置換の場合、NULL値は""(空文字列)に切り詰められます。数値列への置換の場合、警告が表示され、レコードはスキップされます。
  • メッセージは個別に送信されるため、セッション全体はロールバックされません。エラーメッセージはTD Consoleに記録されますが、ジョブは続行されます。
  • Firebaseメッセージテンプレート構造についての十分な知識。

TD Consoleを使用して接続を作成する

新しい接続を作成する

データ連携を設定する場合、統合にアクセスするための認証を提供します。Treasure Dataでは、認証を設定してからソース情報を指定します。

  1. TD Consoleを開きます。
  2. Integrations Hub > Catalogに移動します。
  3. Firebaseを検索して選択します。

次のダイアログが開きます。

4. Google Developer Consoleサービスアカウントから取得した認証情報を入力または貼り付けます。

  1. Doneを選択します。

データ連携でエクスポート結果を設定する

このステップでは、クエリを作成または再利用します。クエリ内で、データ連携を設定します。

パラメータを指定して接続を設定する

  1. TD Consoleを開きます。
  2. Data Workbench > Queriesに移動します。
  3. データのエクスポートに使用する予定のクエリを選択します。
  4. クエリエディタの上部にあるExport Resultsを選択します。Choose Integrationダイアログが開きます。結果のエクスポートに使用する接続を選択する際には、既存の接続を使用するか、新しい接続を作成するかの2つのオプションがあります。

5. 既存の接続を使用する

  1. 検索ボックスに接続名を入力してフィルタリングします。
  2. 接続を選択します
  3. エクスポートの詳細を指定します。

  • Project Id: Firebaseプロジェクトのプロジェクト ID。
  • Message Template: コネクタは、テンプレート内のすべての置換列とエイリアス(___column_name___)を、Firebaseメッセージに送信する個別のメッセージに置き換えます。すべての置換列とエイリアスは、エクスポートデータに存在する必要があります。
  • Fast Mode: 検証、エラーログ、リトライなしで並列実行を有効にします。デフォルト: false
  • Max retries(オプション): システムが諦めるまでのリトライ回数。デフォルト: 7。
  • Initial retry time wait in milliseconds(オプション): 最初と2回目の試行の間の時間(ミリ秒)。デフォルト: 500(0.5秒に相当)。
  • Max retry wait in milliseconds(オプション): 2回目以降のすべての試行の間の時間(ミリ秒)。デフォルト: 300000(5分に相当)。

以下はテンプレート設定のサンプルです:

{
	"message": {
		"notification": {
			"title": "___title___",
			"body": "___body___"
		},
		"topic": "weather"
	}
}

Firebaseにデータを投入するクエリの例

Treasure Dataから次のクエリを実行し、Firebase用の接続に結果をエクスポートします:

Select 'test_body' as body, 'test_title' as title

オプション: エクスポート用のScheduled Jobsを使用する

Result Exportと共にScheduled Jobsを使用して、指定した宛先に定期的に出力結果を書き込むことができます。

Audience Studio で Segment をアクティベートする

Audience Studio で activation を作成することで、segment データをターゲットプラットフォームに送信することもできます。

  1. Audience Studio に移動します。
  2. parent segment を選択します。
  3. ターゲット segment を開き、右クリックして、Create Activation を選択します。
  4. Details パネルで、Activation 名を入力し、前述の Configuration Parameters のセクションに従って activation を設定します。
  5. Output Mapping パネルで activation 出力をカスタマイズします。

  • Attribute Columns
    • Export All Columns を選択すると、変更を加えずにすべての列をエクスポートできます。
    • + Add Columns を選択して、エクスポート用の特定の列を追加します。Output Column Name には、Source 列名と同じ名前があらかじめ入力されます。Output Column Name を更新できます。+ Add Columns を選択し続けて、activation 出力用の新しい列を追加します。
  • String Builder
    • + Add string を選択して、エクスポート用の文字列を作成します。次の値から選択します:
      • String: 任意の値を選択します。テキストを使用してカスタム値を作成します。
      • Timestamp: エクスポートの日時。
      • Segment Id: segment ID 番号。
      • Segment Name: segment 名。
      • Audience Id: parent segment 番号。
  1. Schedule を設定します。

  • スケジュールを定義する値を選択し、オプションでメール通知を含めます。
  1. Create を選択します。

batch journey の activation を作成する必要がある場合は、Creating a Batch Journey Activation を参照してください。

i

オプション: Workflowでエクスポート結果を設定する

Treasure Workflow内で、このデータコネクタを使用してデータをエクスポートすることを指定できます。

timezone: UTC

_export:
  td:
 database: sample_datasets

+td-result-into-firebase:
  td>: queries/sample.sql
  result_connection: your_connections_name
  result_settings:
    service_account_json: '{"type":"service_account","project_id":"project_id","private_key_id":"####"}'
    project_id: project_id
    message_template: {"message":{"notification":{"title":"___title___","body":"___body___"},"topic":"weather"}}
    fast_mode: true
    retry_count: 7
    retry_initial_wait_millis: 500
    max_retry_wait_millis: 300000

オプションとして、workflowでデータコネクタを使用してデータをエクスポートする方法について詳しくお読みください。