ワークフローのインポートでは、規定のフォーマットに従って記述されたJSONファイルを読み込むことでワークフローを作成します。
使用方法
1 ワークフローを新規作成し、バナーにあるImportボタン(下画像で赤枠で囲っている)をクリックしてください。
2 以下の画面が表示されるので問題がなければインポートを選択。
3 インポートしたいjsonファイルを選択しインポート
ImportするJSONファイルのフォーマット
ImportするJSONファイルは以下のようなものです。各フィールドについて解説していきます。
{
"name": "For Import Docs",
"description": "Importの説明用",
"type": "batch",
"dependencies": [
{
"from": "MySQL",
"to": "Google BigQuery"
}
],
"tasks": [
{
"name": "MySQL",
"category": "source",
"subcategory": "mysql",
"property": {
"database": "import_test",
"query": "SELECT * FROM accounts",
"integration_name": "test"
}
},
{
"name": "Google BigQuery",
"category": "sink",
"subcategory": "google_bigquery",
"property": {
"project_id": "google_test",
"dataset": "import_test",
"table": "#{bq_table_name}",
"temporary_gcs_bucket": "import-tmp",
"save_mode": "append",
"integration_name": "test"
}
}
],
"parameters": [
{
"key": "bq_table_name",
"value": "accounts"
}
]
}
基本情報
項目名 | 型 | 入力条件 | 詳細 |
name | string | 必須 | ワークフローの名前を入れる文字列のフィールドです。64文字まで許容します。 |
description | string | 必須 | ワークフローの説明を入力する文字列のフィールドです。64文字まで許容します。 |
type | string | 必須 | ワークフローのタイプを入力する文字列のフィールドです。batchかstreamのみ許容します。 |
dependencies (from) |
string | 必須 |
Taskの繋がりを表す配列のフィールドです。
繋ぎたいTaskの名前を入力します。
|
dependencies (to) |
string | 必須 |
Taskの繋がりを表す配列のフィールドです。
繋ぎたいTaskの名前を入力します。
|
Tasks
必須。ワークフローの持っているTask一覧を入力する配列のフィールドです。
配列の中身は以下のフィールドを持ったオブジェクトです。
項目名 | 型 | 入力条件 | 詳細 |
name | string | 必須 | Task(自身)の名前を入力します。同じワークフロー内の全てのTaskは一意な名前を持つ必要があります。255文字まで許容します。 |
category | string | 必須 | Taskのカテゴリを入力します。カテゴリはsource, transform, analytics, sinkの4つのどれかです。 |
subcategory | string | 必須 | Taskのサブカテゴリを入力します。詳しくは各タスクの詳細ページを参照してください。 |
property | object | 必須 | Taskのプロパティを入力します。詳しくは各タスクの詳細ページを参照してください。 |