注: 以下の翻訳の正確性は検証されていません。AIPを利用して英語版の原文から機械的に翻訳されたものです。
Pipeline Builder で地理空間の時系列プロパティを作成する
このガイドに沿って Pipeline Builder で作成するパイプラインは、生の位置情報の更新から時系列データを生成し、シリーズIDの参照を含むオブジェクトの元データセットを準備します。このデータは、Ship オブジェクトタイプの時系列プロパティに関連付ける時系列同期の元データになります。
この例で使用する架空の生の位置情報データセットには、次の列が含まれています。
- ship_id:
string| 各船舶の一意の識別子。 - timestamp:
timestamp| 位置が記録された時刻。 - longitude:
double| 記録された時刻における船舶の経度。 - latitude:
double| 記録された時刻における船舶の緯度。
以下の生データをコピーし、Foundry にデータセットとしてインポートしてから、Pipeline Builder の新しいパイプラインに追加できます。
| ship_id | timestamp | longitude | latitude |
|---|---|---|---|
| ship-001 | 2025-01-01 08:00:00 | 139.7492 | 35.7607 |
| ship-001 | 2025-01-01 14:00:00 | 140.0097 | 35.2652 |
| ship-001 | 2025-01-01 20:00:00 | 139.5932 | 35.7231 |
| ship-002 | 2025-01-02 08:00:00 | 135.7609 | 35.1223 |
| ship-002 | 2025-01-02 14:00:00 | 135.9821 | 35.3055 |
| ship-002 | 2025-01-02 20:00:00 | 136.2015 | 35.4878 |
パート1：時系列データを加工する
生の位置情報データセットに、Pipeline Builder で次のデータ加工を適用し、時系列同期に対応するデータセットを作成します。
1. 緯度と経度の列をアンピボットする
データセットには緯度と経度が別々の列として含まれているため、アンピボットのデータ加工を使用して、1つの値列に統合します。これは、時系列同期に必要なスキーマに合わせるために必要です。データセットをパイプラインに追加したら、データ加工ノードを追加し、latitude 列と longitude 列をアンピボットして、新しい名前列 series_name と値カラム series_value にします。
2. 文字列を連結のデータ加工を使用して series_id 列を作成する
次に、データ加工ノードを追加し、文字列を連結のデータ加工を使用して series_name 列と ship_id 列を連結し、新しい series_id 列を作成します。
3. オブジェクトの元データセットを作成する
次に、Drop columns (列の削除)、文字列を連結、重複を削除のデータ加工を使用して、Ship オブジェクトタイプの元データセットを作成します。パイプラインでこれらのデータ加工を完了すると、データセットには次のスキーマと値が含まれます。
| longitude_series_id | latitude_series_id | ship_id |
|---|---|---|
| longitude_ship-001 | latitude_ship-001 | ship-001 |
| longitude_ship-002 | latitude_ship-002 | ship-002 |
データ加工ノードを追加し、上記のデータ加工を適用します。
- Drop columns (列の削除)：
timestamp、series_value、series_name、series_idの列を削除します。 - 文字列を連結：セパレーターにアンダースコアを使用し、別々のデータ加工ブロックで
latitude列とlongitude列をそれぞれship_idと連結します。 - 重複を削除：
ship_id列をlatitudeおよびlongitudeとの連結に使用した後で削除します。
データ加工を設定したら、パイプラインのキャンバスに戻り、新しく作成したデータ加工ノードから出力を追加 > 新規データセットを選択して、オブジェクトタイプの元データとなるデータセットを出力します。
データセットに cleansed-ship-information-dataset などの分かりやすい名前を付けます。上部のリボンで保存を選択し、パイプラインをデプロイしてデータセットを作成します。
4. ship_id と series_name を削除してから series_value を Double にキャストする
オブジェクトタイプの元データセットを作成したら、ステップ2で作成したデータ加工ノードに戻り、時系列同期を作成します。
series_id 列と series_value 列は ship_id と series_name から生成され、それらに置き換わるため、データ加工ノードを追加して ship_id と series_name を削除し、series_value を Double 型にキャストします。これにより、クレンジング済みデータセットから、トラックオブジェクトの緯度の追跡プロパティと経度の追跡プロパティの元データとなる時系列同期を出力できます。
パート2：時系列同期を作成する
時系列プロパティのユースケースチュートリアルでも同様の手順を参照できます。ただし、以下の手順では、この Ship 地理空間オブジェクトタイプの例に特化したガイダンスを提供します。
時系列同期の代わりに、新しいデータセットを出力することもできます。ただし、Pipeline Builder で時系列同期を出力すると、オントロジーの設定段階での手順を1つ省けます。
クレンジング済みデータセットから時系列同期を出力するには、パイプラインのキャンバスで最後のデータ加工ノードを選択し、出力を追加 > 新規時系列同期を選択します。次に、パイプラインの右側に表示されるパイプラインの出力ドロワーで、シリーズID、時間、値の選択肢に、クレンジング済みデータセットの series_id、timestamp、series_value 列をそれぞれ指定します。パイプラインを保存してデプロイし、時系列同期を作成します。
Foundry は、新しく作成した時系列同期を、パイプラインと同じ Compass フォルダーに保存します。
時系列同期を作成したら、時系列同期を時系列プロパティとして含むオブジェクトタイプをオントロジーに作成して設定できます。