ホテルの顧客データは、HAPI OPERA Exchange Interface (OXI) を使用した Oracle OPERA を搭載したプロパティ管理システムから簡単に取り込むことができます。このストリーミングインポートインテグレーションは、ホテルが独自のオンプレミスサーバーをホストする必要がなく、HAPI を使用します。
HAPI は、Treasure Data にインポートされるイベントデータの抽出、クリーニング、正規化のプロセスを改善するデータインテグレーションプラットフォームです。
- Treasure Data の基本的な知識
- HAPI の基本的な知識
- TD API 書き込み専用キー
- 各リクエストの Content-Length は 998 KB 以下である必要があります。
- コネクタータイプごとに、アカウントあたり 2 つのソース作成の制限があります。
- 重複イベントは許可されます。
- 新しいソースを作成する前に、データベースを作成する必要があります。
- 新しいソースを作成する前に、少なくとも 1 つのテーブルを作成する必要があります。エンドポイントで使用する前に、必要な追加テーブルを使用する必要があります。
- データが Plazma で利用可能になるまでの予想されるターゲットレイテンシは、5 分から 10 分です。
- TD ユーザーは、HAPI ストリーミングコネクターを作成するために書き込み専用 API キーを使用する必要があります。
- 新しく作成されたソースがデータのストリーミングを開始するまで、数秒の遅延があります。
最初のステップは、認証情報のセットを使用して新しい認証を作成することです。
Integrations Hub を選択します。
Catalog を選択します。

- Catalog でインテグレーションを検索し、アイコンの上にマウスを置いて Create Authentication を選択します。


- New Authentication モーダルが開きます。

- Credentials タブが選択されていることを確認し、インテグレーションの認証情報を入力します。
| フィールド | 説明 |
|---|---|
| API ID (必須) | この接続の API ID |
| TD API Key (必須) | データベースへのアクセスのための TD 書き込み専用 API キー。Getting Your API Keys を参照してください。 |
Continue を選択します。
認証の名前を入力し、Done を選択します。
TD Console を開きます。
Integrations Hub > Authentications に移動します。
新しい認証を見つけて、New Source を選択します。
ソースの以下のテーブルに記入します。
| パラメータ | 説明 |
|---|---|
| Data Transfer Name | 転送の名前を定義できます。 |
| Authentication | 転送に使用される認証名。 |
Data Transfer Name フィールドにソース名を入力します。
Next を選択します。
Create Source ページが表示され、Data Settings タブが選択されています。
以下のパラメータを編集します。
| パラメータ | 説明 |
|---|---|
| Datastore | Plazma が利用可能なオプションです。 |
| Tags (オプション) | タグはこのソースを見つけるために使用できます。 |
| Database | データをインポートする Treasure Data 内のデータベースを指定します。 |
| Table | データを配置するデータベース内のテーブルを指定します。 |
Create を選択します。
HAPI の各エンドポイントに必要なテーブルを作成します。例:
- reservation
- inventory
- profile
- block
- room_stay
- rate
- guest
ソース ID (UUID v4) は、ソースが作成されたときに発行されます。誤用を防ぐために、ソース ID は権限のない人に開示しないでください。HAPI にエンドポイントを登録するには、ソース ID が必要です。
- ソースを作成すると、自動的に Sources リストページに移動します。
- 作成したソースを検索します。
- 同じ行の "..." をクリックし、Copy Unique ID をクリックします。この Unique ID が、HAPI にエンドポイントを登録する際に必要なソース ID です。

エンドポイント登録を完了するには、TD API キー(Getting Your API Keys を参照)とソース ID(ソース ID のコピーセクションを参照)が必要です。次の設定例を使用して、2 つのシークレットを転送するための HAPI との安全なチャネルが必要です。
TD API Key とソース ID を、それぞれTD API キーとソース ID に置き換えてください。
reservation、inventory、profile、block、room_stay、rate、guest は、データ設定の定義で作成された例のテーブルです。
App id: HAPI
API key: TD API Key
Auth endpoint: https://hapi-in-streaming-development.treasuredata.com/v1/authenticate
Message Type endpoints:
RESERVATION: https://hapi-in-streaming-development.treasuredata.com/v1/task/Source Id/table/reservation
INVENTORY: https://hapi-in-streaming-development.treasuredata.com/v1/task/Source Id/table/inventory
PROFILE: https://hapi-in-streaming-development.treasuredata.com/v1/task/Source Id/table/profile
BLOCK: https://hapi-in-streaming-development.treasuredata.com/v1/task/Source Id/table/block
ROOM_STAY: https://hapi-in-streaming-development.treasuredata.com/v1/task/Source Id/table/room_stay
RATE: https://hapi-in-streaming-development.treasuredata.com/v1/task/Source Id/table/rate
GUEST: https://hapi-in-streaming-development.treasuredata.com/v1/task/Source Id/table/guest
TD へのイベントデータの取り込みは、ストリーミングデータソースが作成された後、最初のイベントがトリガーされたときに開始されます。