# Amazon S3 Parquet Export Integration Parquetは、カラム型データフォーマットであり、クエリがデータセット内のカラムのサブセットのみにアクセスする必要がある分析ワークロードに特に有益です。このため、多くのデータパイプライン戦略において好まれるオプションとなっています。 Amazon S3 Parquet Export Integrationを使用すると、Treasure Dataのジョブ結果からParquetファイルを生成し、Amazon S3に直接アップロードできます。 ## 前提条件 - Treasure Dataの基本的な知識 ## S3 Bucket Policy 設定 TD リージョンと同じリージョンにある AWS S3 バケットを使用している場合、TD がバケットにアクセスする IP アドレスはプライベートで動的に変化します。アクセスを制限したい場合は、静的 IP アドレスではなく VPC の ID を指定してください。例えば、US リージョンの場合は vpc-df7066ba 経由でアクセスを設定し、Tokyo リージョンの場合は vpc-e630c182 経由、EU01 リージョンの場合は vpc-f54e6a9e 経由でアクセスを設定してください。 Treasure コンソール にログインする URL から Treasure コンソール のリージョンを確認し、URL 内のリージョンのデータコネクターを参照してください。 詳細については、[API ドキュメント](/apis/endpoints/ip-addresses-integrations-result-workers#s3-bucket-policy-configuration-for-export-and-import-integrations)を参照してください。 ## Treasure Data Integration の静的 IP アドレス セキュリティポリシーで IP ホワイトリストが必要な場合は、接続を成功させるために Treasure Data の IP アドレスを許可リストに追加する必要があります。 リージョンごとに整理された静的 IP アドレスの完全なリストは、次のリンクにあります: [IP Addresses for Integrations](/apis/endpoints/ip-addresses-integrations-result-workers) ## 要件と制限事項 - 最大512 MBの行グループサイズのみをサポートします。 - ファイルのアップロードにマルチパートアップロードが使用されるため、何らかの理由でS3コンテナにアップロードパーツが残る場合があります。不完全なマルチパートアップロードのクリーンアップポリシーを有効にすることをお勧めします。詳細については、[S3 Lifecycle Management Update – Support for Multipart Uploads and Delete Markers](https://aws.amazon.com/blogs/aws/s3-lifecycle-management-update-support-for-multipart-uploads-and-delete-markers/)を参照してください。 # Treasure コンソールで接続を作成する クエリを実行する前に、データ接続を作成して設定する必要があります。データ接続の一部として、統合にアクセスするための認証を提供します。 ## Amazon S3 Parquetでサポートされている認証方法 | 認証方法 | Amazon S3 Parquet | | --- | --- | | **basic** | **x** | | **session** | **x** | | **assume_role** | **x** | ## 認証を作成する 最初のステップは、認証情報のセットを使用して新しい認証を作成することです。 1. **Integrations Hub**を選択します。 2. **Catalog**を選択します。 ![](/assets/26617500.ca92fa4ab9277dca95973c6bd413fc662a3f0d04b57d58f7a8c952a29f28bbec.6bd3f7a7.png) 3. Catalogで統合を検索し、アイコンにマウスカーソルを合わせて**Create Authentication**を選択します。 ![](/assets/26617501.d6a5ad453f9fa98b4336af9506dadbd04ea44299e2f9af7fd760f75ac68e3f88.25ec5a77.png) 4. **Credentials**タブが選択されていることを確認し、統合の認証情報を入力します。 **認証フィールド** | Parameter | Description | | --- | --- | | **Endpoint** | S3サービスエンドポイントのオーバーライド。リージョンとエンドポイント情報は、[AWS service endpoints](http://docs.aws.amazon.com/general/latest/gr/rande.html#s3_region)で確認できます（例：[*s3.ap-northeast-1.amazonaws.com*](https://s3.ap-northeast-1.amazonaws.com/)）。指定すると、リージョン設定が上書きされます。 | | **Region** | AWSリージョン | | **Authentication Method** | | | **basic** | - access_key_idとsecret_access_keyを使用して認証します。[AWS Programmatic access](https://docs.aws.amazon.com/general/latest/gr/managing-aws-access-keys.html)を参照してください。 - Access Key ID - Secret access key | | **session (推奨)** | - 一時的に生成されたaccess_key_id、secret_access_key、およびsession_tokenを使用します。 - Access Key ID - Secret access key - Session token | | **assume_role** | - ロールアクセスを使用します。[AWS AssumeRoleを参照](https://docs.aws.amazon.com/STS/latest/APIReference/API_AssumeRole.html)。 - TDのインスタンスプロファイル - アカウントID - ロール名 - 外部ID - 有効期間(秒) | | **匿名** | サポートされていません | | **アクセスキーID** | AWS S3から発行 | | **シークレットアクセスキー** | AWS S3から発行 | | **セッショントークン** | 一時的なAWSセッショントークン | | **TDのインスタンスプロファイル** | この値はTreasure コンソールによって提供されます。この値の数値部分が、IAMロールを作成する際に使用するアカウントIDを構成します。 | | **アカウントID** | AWSアカウントID | | **ロール名** | AWSロール名 | | **外部ID** | シークレット外部ID | | **有効期間** | 一時的な認証情報の有効期間 | 1. **続行**を選択します。 2. 認証の名前を入力し、**完了**を選択します。 ## *assume_role*認証方式を使用した認証の作成 1. *assume_role*認証方式で新しい認証を作成します。 2. TDのインスタンスプロファイルフィールドの値の数値部分をメモします。 ![](/assets/4f8559a3-4f70-4c83-b8b9-adaaec64662f_1_201_a.1331328bd097ab94743fc3d5f53d63f8cbc98ad689475b3adc5b21335a2e22e3.e7823387.jpeg) 3. AWS IAMロールを作成します。 ![](/assets/ea9e1f37-be45-4ac6-97fa-4b46f65b0388_1_201_a.99af6c7efd4bcd9e50a04d5457e1febf3da2f104b7a090d9bcc307dc3dc8d8c3.e7823387.jpeg) ![](/assets/45c6048c-cc9e-40c1-b0f4-529e356d6e16_1_201_a.bb869c9c9ad66cdecbebc9b2b1231acd5f24c98517c6bc2cfb6ec67efcd884ef.e7823387.jpeg) ## クエリ結果のエクスポートの設定 ### クエリの定義 1. **Data Workbench > Queries**に移動します。 2. 新しいクエリを選択します。 3. クエリを実行して結果セットを検証します。 ![](/assets/export-integration-template_26617476-2024-02-05.7a13029cf9bb61c96f1ef577583007e067c336b7d0cabc7a9222402f86046b29.9f8ceb9f.png) ### 結果エクスポート先の指定 1. **結果をエクスポート**を選択します。 ![](/assets/export-integration-template_26617476-2024-02-05-1.5b83da44688e6582943f259dce9d18f20176855b764e46205a8d99cc64749f96.9f8ceb9f.png) 2. 認証を指定し、エクスポートの設定を開始します。 既存の認証を選択するか、出力に使用する外部サービス用の新しい認証を作成できます。次のいずれかを選択します: **既存のIntegrationを使用する** ![](/assets/export-integration-template_26617476-2024-02-05-2.654362d5d36805519ec64f0c0dcb467e4921dcd3e2760a0f6f6d4b2ddb672a3a.9f8ceb9f.png) **新しいIntegrationを作成する** ![](/assets/amazon-s3-parquet-export-integration-2024-11-05.a702f34211c01d44256ed868e8c6024c0c4a1a3fc127da746df23a359fb518a1.e18fb3ca.png)** ![](/assets/s3-parquet-export-integration-2024-05-23-2.0f3e2a3772669df4a2b3e2e03558df8b7d140d35dddebdcf3c01b227453f21f7.2a336cf9.png) ### 設定フィールド | フィールド | 説明 | | --- | --- | | Server-side encryption | サポートされる値:- sse-s3: Server-side Encryption Mode - sse-kms: 新しいSSE Mode | | Server-side Encryption Algorithm | サポートされる値: - AES256 | | KMS Key ID | 対称AWS KMS Key ID。KMS Key IDの入力がない場合、デフォルトのKMS Keyを作成/使用します。 | | Bucket | S3バケット名を指定してください (例: your_bucket_name)。 | | Compression | S3バケット名を指定してください (例: your_bucket_name)。 | | Path | s3ファイル名(オブジェクトキー)を指定し、拡張子を含めてください (例: test.parquet)。 | | Compression | エクスポートされるファイルの圧縮形式。サポートされる値: - None - Gzip - Snappy | | Row group size | Parquetファイルのグループサイズを指定してください | | Page size | Parquetファイルのページサイズを指定してください | | Timestamp Unit | Parquetファイルのタイムスタンプ形式を指定してください。サポートされる時間単位:- Milliseconds - Microseconds | | Single file | Row Groupのサイズで複数のファイルに分割する場合はチェックを外してください | | Enable Bloom filter | ParquetファイルのBloom filterを有効にする | | リトライ制限 | 最大リトライ回数 | | リトライ待機時間 | 各リトライ時の待機時間(ミリ秒) | | 同時実行スレッド数 | S3へのアップロードを行うS3スレッドの同時実行数 | | スレッドあたりの接続数 | S3への各スレッドが開くHTTP接続数 | | パートサイズ | S3のマルチパートアップロードのパートサイズ | # Audience Studioでアクティベーションを作成する [アクティベーションを作成](https://docs.treasuredata.com/smart/project-product-documentation/create-an-activation)して、セグメントデータやステージをエクスポートできます。 ## 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 出力をカスタマイズします。 ![](/assets/ouput.b2c7f1d909c4f98ed10f5300df858a4b19f71a3b0834df952f5fb24018a5ea78.8ebdf569.png) - 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** を設定します。 ![](/assets/snippet-output-connector-on-audience-studio-2024-08-28.a99525173709da1eb537f839019fa7876ffae95045154c8f2941b030022f792c.8ebdf569.png) - スケジュールを定義する値を選択し、オプションでメール通知を含めます。 1. **Create** を選択します。 batch journey の activation を作成する必要がある場合は、[Creating a Batch Journey Activation](/products/customer-data-platform/journey-orchestration/batch/creating-a-batch-journey-activation) を参照してください。 ### (オプション) Query Export ジョブをスケジュールする Scheduled Jobs と Result Export を使用して、指定したターゲット宛先に出力結果を定期的に書き込むことができます。 Treasure Data のスケジューラー機能は、高可用性を実現するために定期的なクエリ実行をサポートしています。 2 つの仕様が競合するスケジュール仕様を提供する場合、より頻繁に実行するよう要求する仕様が優先され、もう一方のスケジュール仕様は無視されます。 例えば、cron スケジュールが `'0 0 1 * 1'` の場合、「月の日」の仕様と「週の曜日」が矛盾します。前者の仕様は毎月 1 日の午前 0 時 (00:00) に実行することを要求し、後者の仕様は毎週月曜日の午前 0 時 (00:00) に実行することを要求するためです。後者の仕様が優先されます。 #### Treasure コンソール を使用してジョブをスケジュールする 1. **Data Workbench > Queries** に移動します 2. 新しいクエリを作成するか、既存のクエリを選択します。 3. **Schedule** の横にある None を選択します。 ![](/assets/image2021-1-15_17-28-51.f1b242f6ecc7666a0097fdf37edd1682786ec11ef80eff68c66f091bc405c371.0f87d8d4.png) 4. ドロップダウンで、次のスケジュールオプションのいずれかを選択します: ![](/assets/image2021-1-15_17-29-47.45289a1c99256f125f4d887e501e204ed61f02223fde0927af5f425a89ace0c0.0f87d8d4.png) | ドロップダウン値 | 説明 | | --- | --- | | Custom cron... | [Custom cron... の詳細](#custom-cron-details)を参照してください。 | | @daily (midnight) | 指定されたタイムゾーンで 1 日 1 回午前 0 時 (00:00 am) に実行します。 | | @hourly (:00) | 毎時 00 分に実行します。 | | None | スケジュールなし。 | #### Custom cron... の詳細 ![](/assets/image2021-1-15_17-30-23.0f94a8aa5f75ea03e3fec0c25b0640cd59ee48d1804a83701e5f2372deae466c.0f87d8d4.png) | **Cron 値** | **説明** | | --- | --- | | `0 * * * *` | 1 時間に 1 回実行します。 | | `0 0 * * *` | 1 日 1 回午前 0 時に実行します。 | | `0 0 1 * *` | 毎月 1 日の午前 0 時に 1 回実行します。 | | "" | スケジュールされた実行時刻のないジョブを作成します。 | ``` * * * * * - - - - - | | | | | | | | | +----- 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. 各フィールド間には単一のスペースが必要です。各フィールドの値は、次のもので構成できます: div | フィールド値 | 例 | 例の説明 | | --- | --- | --- | | 各フィールドに対して上記で表示された制限内の単一の値。 | | | | フィールドに基づく制限がないことを示すワイルドカード `'*'`。 | `'0 0 1 * *'` | 毎月 1 日の午前 0 時 (00:00) に実行するようにスケジュールを設定します。 | | 範囲 `'2-5'` フィールドの許可される値の範囲を示します。 | `'0 0 1-10 * *'` | 毎月 1 日から 10 日までの午前 0 時 (00:00) に実行するようにスケジュールを設定します。 | | カンマ区切りの値のリスト `'2,3,4,5'` フィールドの許可される値のリストを示します。 | `0 0 1,11,21 * *'` | 毎月 1 日、11 日、21 日の午前 0 時 (00:00) に実行するようにスケジュールを設定します。 | | 周期性インジケータ `'*/5'` フィールドの有効な値の範囲に基づいて、 スケジュールが実行を許可される頻度を表現します。 | `'30 */2 1 * *'` | 毎月 1 日、00:30 から 2 時間ごとに実行するようにスケジュールを設定します。 `'0 0 */5 * *'` は、毎月 5 日から 5 日ごとに午前 0 時 (00:00) に実行するようにスケジュールを設定します。 | | `'*'` ワイルドカードを除く上記の いずれかのカンマ区切りリストもサポートされています `'2,*/5,8-10'` | `'0 0 5,*/10,25 * *'` | 毎月 5 日、10 日、20 日、25 日の午前 0 時 (00:00) に実行するようにスケジュールを設定します。 | 1. (オプション) Delay execution を有効にすることで、クエリの開始時刻を遅延させることができます。 # (オプション) Workflowでエクスポート結果を設定する Treasure ワークフロー内で、この連携を使用してデータをエクスポートするように指定できます。 ``` _export: td: database: td.database +a_s3_parquet_export_task: td>: export_test.sql database: ${td.database} result_connection: s3_parquet_conn result_settings: type: ``` # (オプション) CLIを使用したエクスポート連携 単一のクエリ結果をS3バケットに出力するには、**td query**コマンドに*--result*オプションを追加します。ジョブが完了すると、結果がS3バケットに書き込まれます。**td query**コマンドについては、[こちらの記事](/tools/cli-and-sdks/td-toolbelt-job-and-query-command-reference)を参照してください。 以下のように、*--result*パラメータを使用してS3へのエクスポートの詳細設定を指定できます: ```json { "type": "s3_parquet", "endpoint": "", "region": "us-east-1", "auth_method": "", "session_token": "", "account_id": "", "role_name": "", "duration_in_seconds": 3600, "access_key_id": "xxxxx", "secret_access_key": "xxxxx", "sse_type": "sse-s3", "sse_algorithm": "AES256", "kms_key_id": "arn:aws:kms:us-east-1:xxx:key/xxx", "bucket": "bucket", "path": "file.parquet", "row_group_size": 256, "page_size": 1024, "timestamp_unit": "milliseconds", "enable_bloom_filter": false, "enable_single_file": true, "compression": "gzip", "part_size": 100, "part_size": 100, "retry_limit": 7, "retry_wait_millis": 500, "number_of_concurrent_threads": 4, "connections_per_thread": 128, } ``` ## パラメータ | 名前 | 説明 | 値 | デフォルト値 | 必須 | | --- | --- | --- | --- | --- | | type | エクスポート先サービスの名前を記述します。 | s3_parquet | N/A | Yes | | endpoint | S3 サービスエンドポイントのオーバーライド。AWS サービスエンドポイントでリージョンとエンドポイント情報を確認できます。(例: s3.ap-northeast-1.amazonaws.com) | S3 サービスエンドポイントのオーバーライド | N/A | No | | region | AWS リージョン | AWS リージョン | us-east-1 | No | | auth_method | S3 の認証方式 | basic session assume_role | basic | Yes | | access_key_id | アクセスキー ID | キー ID | N/A | auth_method として basic または session を使用する場合 | | secret_access_key | シークレットアクセスキー | シークレットアクセスキー | N/A | auth_method として basic または session を使用する場合 | | session_token | セッショントークン | セッショントークン | N/A | auth_method として session を使用する場合 | | account_id | アカウント ID | アカウント ID | N/A | auth_method として assume_role を使用する場合 | | role_name | ロール名 | ロール名 | N/A | auth_method として assume_role を使用する場合 | | external_id | 外部 ID | 外部 ID | N/A | auth_method として assume_role を使用する場合 | | duration_in_seconds | 接続の持続時間 | 秒単位の持続時間 | 3600 | No | | bucket | S3 バケット値 | S3 バケット値 | N/A | Yes | | path | ファイル形式を含む S3 パス (例: "/path/file.parquet") | パスファイル | N/A | Yes | | row_group_size | Parquet 行グループサイズ | Parquet 行グループサイズ | 256 | No | | page_size | Parquet ページサイズ | Parquet ページサイズ | 1024 | No | | timestamp_unit | Parquet タイムスタンプ形式 | - milliseconds - microseconds | milliseconds | No | | enable_bloom_filter | Parquet ファイルのブルームフィルタを有効化 | - true - false | false | No | | enable_single_file | 単一ファイルへのエクスポート、または各ファイルに1つの *row_group_file* を含む複数ファイルへのエクスポートを有効化 | - true - false | true | Y | | compression | エクスポートされたファイルの圧縮形式 | - None - Gzip - Snappy | None | No | | retry_limit | 最大リトライ回数 | リトライ制限 | 7 | No | | retry_wait_millis | 各リトライ時の待機時間(ミリ秒) | リトライ待機時間(ミリ秒) | 500 | No | | number_of_concurrent_threads | S3 へのアップロードのための同時スレッド数 | 同時 S3 スレッド数 | 4 | No | | connection_per_thread | S3 への各スレッドごとの HTTP 接続数 | スレッドごとの HTTP 接続数 | 16 | No | | part_size | S3 のマルチパートアップロードのパートサイズ | パートサイズ | 100 | No | ## 使用例 ```bash $ td query \ --result '{"type":"s3_parquet","auth_method":"basic","access_key_id":"access_key_id","secret_access_key":"secret_access_key","bucket":"bucket","path":"/path/file.parquet"}' \ -d sample_datasets "select * from www_access" -T presto ```