Rokt Via SFTP Export Integration

Copy

• Copy for LLM

  Copy page as Markdown for LLMs
• View as Markdown

  Open this page as Markdown
• Open in ChatGPT

  Get insights from ChatGPT
• Open in Claude

  Get insights from Claude
• Cursorに接続

  CursorにMCPサーバーをインストール
• VS Codeに接続

  VS CodeにMCPサーバーをインストール

Roktは、取引時点（購入直後など）にパーソナライズされたオファーや広告を表示することを専門とするEコマースエンゲージメント・収益化プラットフォームです。

このドキュメントでは、Secure FTP（SFTP） を使用してカスタムオーディエンスリストとコンバージョンデータをアップロードすることで、Treasure Data CDPとRoktを統合する方法について説明します。ファイルベースの統合を活用することで、企業はリアルタイムAPI接続に依存せずに、主要なマーケティングデータの同期を自動化できます。

CDP統合のユースケース

CDP to Rokt: パーソナライゼーション強化のためのセグメントデータ送信

目標: CDPで構築されたオーディエンスセグメントを活用してオファーターゲティングを改善する。

ユースケース:

• 顧客が既に所有している製品/サービスのオファーを抑制する（例：既存のクレジットカード保有者を除外）。
• VIPまたはロイヤルカスタマーに対して高価値オファーを優先する。

Roktでオファーパーソナライゼーションを推進するためにCDP属性を使用

目標: CDP拡張属性（推測された興味、ロイヤルティスコアなど）を活用してRoktエクスペリエンスをパーソナライズする。

ユースケース:

• 年齢層、製品親和性、解約リスクなどのCDP生成属性を使用して、Roktのオファー選択に影響を与える。

CDP to Rokt（コンバージョン）

目標: CDPからコンバージョンイベント（購入、サインアップ、キャンセルなど）をエクスポートし、ファイルアップロード経由でRoktに送信する。

ユースケース:

• キャンペーン最適化を強化する。
• アトリビューションの精度を向上させる。

前提条件

• Roktアカウントマネージャーに連絡してSFTP認証情報を取得してください。
• CDPの親セグメントにプレーンテキストメールまたはSHA-256ハッシュ化メールのいずれかが含まれていることを確認してください。

Treasure Data Integration の静的 IP アドレス

セキュリティポリシーで IP ホワイトリストが必要な場合は、接続を成功させるために Treasure Data の IP アドレスを許可リストに追加する必要があります。

リージョンごとに整理された静的 IP アドレスの完全なリストは、次のリンクにあります: https://api-docs.treasuredata.com/en/overview/ip-addresses-integrations-result-workers/

基本的な使用方法

RoktはSFTP経由で以下のインポートをサポートしています：

• カスタムオーディエンスリスト: キャンペーンでのインクルージョンまたはエクスクルージョンターゲティング用。
• コンバージョンデータ: キャンペーン測定、最適化、およびアトリビューション用。

詳細については、以下を参照してください：

• Import custom audiences | Rokt documentation
• Import conversions via file transfer | Rokt documentation

新しい接続の作成

クエリを実行する前に、TD Consoleでデータ接続を作成および設定する必要があります。データ接続の一部として、以下の手順で統合にアクセスするための認証を提供します：

1. TD Consoleを開きます。

2. Integrations Hub > Catalogに移動します。

3. SFTP_V2を検索し、Create Authenticationを選択します。

4. 接続認証情報を提供します。

   

   認証フィールド

1. Continueを選択し、Authenticationの名前を入力します。
2. Doneを選択します。

エクスポート用のクエリ結果の設定

TD Consoleは、データをエクスポートする複数の方法をサポートしています。Data Workbenchからデータをエクスポートするには、以下の手順を完了してください。

1. Data Workbench > Queriesに移動します。

2. New Queryを選択し、クエリを定義します。

3. Export Resultsを選択し、データエクスポート設定を提供します。

4. 既存の統合を使用するか、新しい統合を作成します。

5. エクスポートパラメータを設定し、Doneを選択します。

   エクスポート設定パラメータ

(オプション) Query Export ジョブをスケジュールする

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

Treasure Data のスケジューラー機能は、高可用性を実現するために定期的なクエリ実行をサポートしています。

2 つの仕様が競合するスケジュール仕様を提供する場合、より頻繁に実行するよう要求する仕様が優先され、もう一方のスケジュール仕様は無視されます。

例えば、cron スケジュールが '0 0 1 * 1' の場合、「月の日」の仕様と「週の曜日」が矛盾します。前者の仕様は毎月 1 日の午前 0 時 (00:00) に実行することを要求し、後者の仕様は毎週月曜日の午前 0 時 (00:00) に実行することを要求するためです。後者の仕様が優先されます。

TD Console を使用してジョブをスケジュールする

1. Data Workbench > Queries に移動します

2. 新しいクエリを作成するか、既存のクエリを選択します。

3. Schedule の横にある None を選択します。

4. ドロップダウンで、次のスケジュールオプションのいずれかを選択します:

   ドロップダウン値	説明
   Custom cron...	Custom cron... の詳細を参照してください。
   @daily (midnight)	指定されたタイムゾーンで 1 日 1 回午前 0 時 (00:00 am) に実行します。
   @hourly (:00)	毎時 00 分に実行します。
   None	スケジュールなし。

Custom cron... の詳細

 *    *    *    *    *
 -    -    -    -    -
 |    |    |    |    |
 |    |    |    |    +----- day of week (0 - 6) (Sunday=0)
 |    |    |    +---------- month (1 - 12)
 |    |    +--------------- day of month (1 - 31)
 |    +-------------------- hour (0 - 23)
 +------------------------- min (0 - 59)

次の名前付きエントリを使用できます:

• Day of Week: sun, mon, tue, wed, thu, fri, sat.
• Month: jan, feb, mar, apr, may, jun, jul, aug, sep, oct, nov, dec.

各フィールド間には単一のスペースが必要です。各フィールドの値は、次のもので構成できます:

1. (オプション) Delay execution を有効にすることで、クエリの開始時刻を遅延させることができます。

クエリを実行する

クエリに名前を付けて保存して実行するか、単にクエリを実行します。クエリが正常に完了すると、クエリ結果は指定された宛先に自動的にエクスポートされます。

(オプション) Delay execution を有効にすることで、クエリの開始時刻を遅延させることができます。

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 番号。

6. Schedule を設定します。

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

7. Create を選択します。

（オプション）CLIを使用したエクスポート統合

TD Toolbeltを使用すると、CLIからSFTPへのクエリ結果のエクスポートをトリガーできます。td queryコマンドの--resultオプションを使用して、エクスポートジョブのパラメータを指定する必要があります。詳細については、Querying and Importing Data to Treasure Data from the Command Lineを参照してください。

オプションの形式はJSONであり、一般的な構造は以下のとおりです：

ユーザー名とパスワードを使用した認証

{
  "type": "sftp_v2",
  "host": "IP or host of SFTP server",
  "port": 22,
  "path_prefix": "/upload/2024Aug29/TC01.csv",
  "temp_file_threshold": 1024,
  "timeout": 600,
  "user_directory_is_root": false,
  "rename_file_after_upload": true,
  "auth_method": "password",
  "username": "login user",
  "password": "password of user when auth_method is password"
}

公開鍵/秘密鍵ペアを使用した認証

{
  "type": "sftp_v2",
  "host": "IP or host of SFTP server",
  "port": 22,
  "path_prefix": "/upload/2024Aug29/TC01.csv",
  "temp_file_threshold": 1024,
  "timeout": 600,
  "user_directory_is_root": false,
  "rename_file_after_upload": true,
  "auth_method": "key_pair",
  "secret_key_file": "Content of private key file",
  "secret_key_passphrase": "td@123"
}

CLIパラメータ

td ... --result '{"type":"sftp_v2", "secret_key_file": "-----BEGIN OPENSSH PRIVATE KEY-----\nline1\nline2\nline3\n-----END OPENSSH PRIVATE KEY-----\n\n"}'

-----BEGIN OPENSSH PRIVATE KEY-----
line1
line2
line3
-----END OPENSSH PRIVATE KEY-----

-----BEGIN OPENSSH PRIVATE KEY-----line1line2line3-----END OPENSSH PRIVATE KEY-----

quote_policy: ALL,
quote: "'",

'id'|'column01'|'column02'|'column03'|'column04'|'column05'
'1'|'data01'|'data02'|'data03'|'data04'|'data05'

quote_policy: MINIMAL,
quote: "'",

id|column01|column02|column03|column04|column05
1|data01|data02|data03|data04|data05

quote_policy: ALL,
quote: "'",

'id'|'column01'|'column02'
'1'|'data01'|'data02'

quote_policy: ALL,
quote: "\"",

"id"|"column01"|"column02"
"1"|"data01"|"data02"

使用例

1. パスワード認証を使用する場合

   td --database your_db --wait "SELECT email FROM (VALUES ('test01@test.com')) tbl(email)" \
   --type presto \
   --result '{"type":"sftp_v2","host":"your_ip","port": 22,"auth_method":"password","username":"user_name","password":"your_pass", "user_directory_is_root": true, "rename_file_after_upload": true,"path_prefix":"/sftp/2024aug/test.csv"}'

2. パスワード認証とデータ圧縮を使用する場合

   td --database your_db --wait "SELECT email FROM (VALUES ('test01@test.com')) tbl(email)" \
   --type presto \
   --result '{"type":"sftp_v2","host":"your_ip","port": 22,"auth_method":"password","username":"user_name","password":"password","user_directory_is_root":true,"path_prefix":"/sftp/2024aug/test.csv","rename_file_after_upload":true,"format": "csv", "compression": "gz","header_line":true,"quote_policy":"ALL","delimiter":"\t","null_string":"","newline":"CRLF","temp_file_threshold":0,"sequence_format":".%01d%01d"}'

3. パスワードフレーズ付きの公開鍵/秘密鍵認証を使用する場合

   秘密鍵ファイルの内容（パスワードフレーズは 123）:

   -----BEGIN OPENSSH PRIVATE KEY-----
   line1
   line2
   line3
   -----END OPENSSH PRIVATE KEY-----

   CLIのフォーマット:

   -----BEGIN OPENSSH PRIVATE KEY-----\nline1\nline2\nline3\n-----END OPENSSH PRIVATE KEY-----\n\n

   CLIコマンド:

   td --database your_db --wait "SELECT email FROM (VALUES ('test01@test.com')) tbl(email)" \
   --type presto \
   --result '{"type":"sftp_v2","host":"your_ip","port": 22,"auth_method":"key_pair","username":"user_name", "path_prefix": "/sftp/2024aug/test.csv","sequence_format":"","max_connection_retry":5,"secret_key_passphrase":"123","timeout":600,"secret_key_file":"-----BEGIN OPENSSH PRIVATE KEY-----\nline1\nline2\nline3\n-----END OPENSSH PRIVATE KEY-----\n\n"}'

4. 新規顧客を作成する場合

   td --database luan_db --wait "SELECT customer_list_id,first_name,last_name,birthday,company_name,email,fax,gender,job_title,phone_business,phone_home,phone_mobile,second_name,credentials FROM (VALUES ('site_1','fname_201','lname_1','1990-05-12','Test Company',

5. 暗号化エンコーダーを使用する場合

   td query -d luan_db -w "select * from luan_db.sfcc_500k" -T presto --result '{
     "type": "sftp_v2",
     "host": "your host server",
     "auth_method": "password",
     "username": "your user name",
     "password": "your password",
     "path_prefix": "cli/test_27_3_500K.csv.bz2.gpg",
     "file_ext": ".gpg",
     "rename_file_after_upload": false,
     "formatter": {
       "type": "csv",
       "quote_policy": "MINIMAL",
       "delimiter": ",",
       "null_string": "null",
       "newline": "\n"
     },
     "compression": "encrypt_pgp",
     "public_key": "your public key",
     "key_identifier": "your key identifier",
     "armor": true/false,
     "compression_type": "bzip2/gzip/none"
   }'

（オプション）その他の考慮事項

Treasure Workflowでは、このインテグレーションを使用してデータをエクスポートすることができます。サンプルワークフローについては、Treasure Boxesをご覧ください。

• 結果のエクスポートをスケジュール設定して、データを定期的にターゲットの宛先にアップロードできます
• ほとんどのインポートおよびエクスポートインテグレーションは、TD Workflowに追加して、より高度なデータパイプラインに組み込むことができます。詳細についてはこちらを参照してください。

SFTPデータコネクタのFAQ

Q: SFTPサーバーに接続できません。どうすればよいですか？

A: 以下の点を確認してください:

• プロトコルが有効であることを確認してください。SFTPを使用する場合は、このインテグレーションを使用できます。FTP/FTPSを使用する場合は、FTP Server Import Integrationで接続を試してください。
• ファイアウォールを使用している場合は、許可されたIP範囲とポートを確認してください。サーバー管理者は、セキュリティ上の理由から、デフォルトのポート番号TCP 22を変更することがあります。
• 秘密鍵がOpenSSH形式であることを確認してください。Treasure Dataは「PuTTY」などの他の形式をサポートしていません。
• Treasure DataはOpenSSH 7.8以降の秘密鍵のデフォルト形式をサポートしていません。'-m PEM'オプションを使用して鍵を再生成してください。

Q: SFTPサーバーにアップロードしたファイルが見つかりません。何が起こったのでしょうか？

A: SFTPサーバーがAppendモードをサポートしていない場合、インテグレーションは「SFTP Exception: no such file.」というエラーでファイルを更新できない可能性があります。安定性の理由から、インテグレーションはファイルコンテンツをバッチでアップロードします。そのため、SFTPサーバーでAppendモードを有効にする必要があります。SFTPサーバーでAppendモードを有効にできない場合は、この機能をバイパスするために temp_file_threshold を 0 に設定する必要があります。

注: ファイルを暗号化してアップロードする前に、必ず圧縮してください。

1. 非組み込み暗号化を使用して復号化すると、ファイルは.gzや.bz2などの圧縮形式に戻ります。

2. 組み込み暗号化を使用して復号化すると、ファイルは生データに戻ります。