Zoho DataPrepでは、Zoho Flowを使用してパイプラインを実行できます。Zoho Flowは、クラウドアプリケーションを連携するためのプラットフォームです。ワークフローを設定して、利用中のアプリ間での情報交換を自動化できます。
例として、次のフローを再作成する手順を説明します。
Zoho WorkDriveに新しいファイルが追加されると、フローによってパイプラインが実行され、新しく追加されたWorkDriveファイルがインポートされます。
重要:Zoho Flowでパイプラインを実行する処理を追加する場合は、Zoho DataPrepで設定する必要があります。
DataPrepでZoho Flowを設定するには、次の手順を実行します。
ヒント:[実行する]ボタンを使用して、パイプラインを実行してみることをお勧めします。各実行は処理として保存されます。2. [スケジュール]のドロップダウンアイコンをクリックし、[Zoho Flow]をクリックします。
データに無効な値がある場合はエクスポートを停止する:有効にすると、データに無効な値が残っている場合にエクスポートが停止します。
エクスポートの順番:
複数のエクスポート先を設定している場合に、各エクスポート先へデータをエクスポートする順番を指定できます。
有効にしない場合、エクスポートは標準の順番で実行されます。
メモ:この設定は、パイプラインに複数のエクスポート先を追加している場合にのみ表示されます。
エクスポート先の順番を変更するには
1) [エクスポートの順番]の切り替えボタンをクリックします。
2) ドラッグ&ドロップでエクスポート先の順番を変更し、[保存する]をクリックします。
メモ:順番を再度変更する場合は、[順番を編集する]リンクをクリックします。3. Zoho Flowを設定する際は、すべてのデータソースにインポート設定を行う必要があります。インポート設定を行わないと、Zoho Flowの設定を保存できません。
[こちらで編集する]リンクを選択して、インポート設定を行います。
インポート設定はデータソースによって異なります。各種データソースのインポート設定方法については、こちらをクリックしてください。
4. Zoho Flowの設定が完了したら、[保存する]をクリックします。
1. Zoho Flowアカウントにログインします。[自分のフロー]セクションの右上にある[フローの作成]、または左側の[+]ボタンをクリックします。
2. フローの名前と説明(任意)を入力します。[作成]をクリックすると、ビルダー画面が表示されます。
4. フローをトリガーするアプリを選択し、[次へ]をクリックします。
5. フローをトリガーするアプリ内のイベントを選択し、[次へ]をクリックします。
利用できるトリガーの種類はアプリによって異なります。
情報:DataPrepで利用できるトリガーは[パイプライン処理の完了]のみです。
6. データ連携をまだ作成していない場合は、[接続]をクリックし、データ連携を認証します。認証方法はアプリによって異なります。
7. データ連携を設定すると、変数名が自動入力されます。必要に応じて名前を編集できます。
メモ:変数名を変更する場合は、次の点に注意してください。
すべての名前は英字で始める必要があります。変数名には、英数字とアンダースコアを使用できます。
スペースなど、その他の文字は使用できません。名前の競合を避けるため、名前は一意である必要があります。
同じ変数名を複数の処理に使用した場合、最後に実行された処理の結果が変数に保存されます。例:new_deal、createTask
8. ドロップダウンから必要なデータを選択し、[完了]をクリックします。
メモ:Zoho DataPrepに連携すると、フィルター条件に次の変数を使用できます。[値]列の値を使用して、フィルター条件を設定できます。N/A,と表示されている項目には、必要に応じて適切な値を入力してください。
|
変数
|
例
|
|
組織ID |
N/A
|
|
ワークスペースID |
N/A
|
|
パイプラインID |
N/A
|
|
処理の実行ステータス |
FAILURE,RUNNING,SUCCESS,CREATED,SKIPPED
|
|
Unixタイムスタンプ形式の処理完了日時 |
N/A
|
|
処理ID |
N/A
|
|
作成者のメールアドレス |
N/A |
|
Unixタイムスタンプ形式のデータ範囲の終了日時 |
N/A
|
|
Unixタイムスタンプ形式のデータ範囲の開始日時 |
N/A
|
|
Unixタイムスタンプ形式の処理作成日時 |
N/A
|
|
無効なデータが原因でエクスポートが停止したか |
TRUE/FALSE
|
|
処理の再実行回数 |
N/A
|
|
処理の種類 |
MANUAL,SCHEDULE,RELOAD,BACKFILL,WEBHOOK,ZOHO FLOW
|
情報:DataPrepで利用できるのは、[パイプラインを実行する]処理のみです。10. 表示された設定画面でデータ連携を選択し、表示される項目にデータを入力します。
データ連携をまだ作成していない場合は、[連携する]をクリックして、データ連携を認証します。認証方法はアプリによって異なります。
a)[連携する]をクリックし、データ連携に名前を付けます。
b)[認証する]をクリックし、表示されたポップアップで承認します。
c)Zoho DataPrepアカウントがZoho Flowと連携されます。
11. データ連携を設定すると、変数名が自動入力されます。必要に応じて名前を編集できます。
12. ドロップダウンから[組織ID]、[ワークスペースID]、および[パイプラインID]を選択し、[完了]をクリックします。
メモ:選択したアプリに応じて変数を挿入し、変数名やメッセージを作成できます。
DataPrepでは、フィルター条件に使用できる次の変数が用意されています。[例]列の値を使用して、フィルター条件を設定できます。N/A,と記載されている項目には、必要に応じて適切な値を入力してください。
|
変数
|
説明 |
例
|
|
組織ID |
パイプラインの組織IDです。 |
N/A
|
|
ワークスペースID |
パイプラインのワークスペースIDです。 |
N/A
|
|
パイプラインID |
選択したパイプラインのIDです。 |
N/A
|
|
処理の実行ステータス |
処理が成功したか失敗したかを示すステータスです。 |
FAILURE,RUNNING,SUCCESS,CREATED,SKIPPED
|
|
Unixタイムスタンプ形式の処理完了日時 |
処理にかかった合計時間です。 |
N/A
|
|
処理ID |
実行した処理のIDです。 |
N/A
|
|
作成者のメールアドレス |
パイプラインを実行したユーザーのメールアドレスです。 |
N/A
|
|
Unixタイムスタンプ形式のデータの範囲の終了日時 |
パイプラインの実行が開始された日時です。 |
N/A
|
|
Unixタイムスタンプ形式のデータの範囲の開始日時 |
パイプラインの実行が呼び出された日時です。 |
N/A
|
|
Unixタイムスタンプ形式の処理作成日時 |
処理が作成された日時です。 |
N/A
|
|
無効なデータによってエクスポートが停止したか |
[データに無効な値が含まれている場合、エクスポートを停止する]設定が有効で、エクスポート時にパイプラインに無効なデータが含まれている場合は「はい」、それ以外の場合は「いいえ」です。 |
TRUE/FALSE
|
|
処理の再実行回数 |
処理が再実行された回数です。 |
N/A
|
|
処理の種類 |
操作を開始する処理の種類です(予約、手動、ウェブフック、Zoho Flow、バックフィル)。 |
MANUAL,SCHEDULE,RELOAD,BACKFILL,WEBHOOK,ZOHO FLOW
|
重要:パイプラインを実行する操作を追加する場合は、Zoho DataPrepで設定する必要があります。
DataPrepでパイプラインにZoho Flowを設定するには、パイプラインの作成画面に移動し、右上の[予約する]ドロップダウンをクリックして、[Zoho Flow]を選択します。DataPrepでZoho Flowを設定する方法の詳細については、こちらをご覧ください。
13. Zoho Flowでは、フローは標準で自動保存されます。フローを有効にすると、下書きが有効版として公開され、バージョンとして保存されます。以降の変更は下書きとして保存されます。変更内容をフローに反映するには、[変更を適用する]をクリックします。
15. Zoho WorkDriveに新しいファイルがアップロードされるたびに、Zoho Flowが自動的にトリガーされ、Zoho DataPrepで設定済みのパイプラインが実行されます。
Zoho Flowの各実行は、DataPrepでジョブとして保存されます。パイプラインを実行すると、データソースからデータが取得され、各ステージに適用済みの一連の加工処理によってデータが準備された後、一定間隔でエクスポート先にエクスポートされます。この一連のプロセスは、ジョブの履歴に記録されます。
ジョブの概要では、ジョブのステータスと詳細を確認できます。[こちらをクリック]すると、ジョブの概要について詳しく確認できます。
メモ:パイプラインにさらに変更を加えると、その変更は下書きバージョンとして保存されます。変更をZoho Flowの実行に反映するには、[下書き]オプションを選択し、パイプラインを準備完了に設定します。
Zoho Flowを設定した後、パイプラインの作成画面で[編集する]または[削除する]を、[Zoho Flowの有効化]オプションから選択できます。
a)[連携する]をクリックし、データ連携に名前を付けます。
b)[承認する]をクリックし、表示されたポップアップで承認します。
c)Zoho DataPrepアカウントがZoho Flowに連携されます。
d)データ連携を設定すると、変数名が自動入力されます。必要に応じて名前を編集できます。
e)ドロップダウンから、[組織ID]、[ワークスペースID]、および[パイプラインID]を選択します。
f)次の[フィルター条件]を使用してフローをトリガーする条件を設定し、[完了]をクリックします。
DataPrepでは、フィルター条件に使用できる次の変数が用意されています。[例]列の値を使用して、フィルター条件を設定できます。N/A,と記載された項目には、必要に応じて適切な値を指定してください。
|
変数
|
説明
|
例
|
|
組織ID |
パイプラインの組織IDです。 |
N/A
|
|
ワークスペースID |
パイプラインのワークスペースIDです。 |
N/A
|
|
パイプラインID |
パイプラインのIDです。 |
N/A
|
|
処理の実行ステータス |
処理の成功または失敗のステータスです。 |
FAILURE,RUNNING,SUCCESS,CREATED,SKIPPED |
|
Unixタイムスタンプ形式の処理完了日時 |
処理にかかった合計時間です。 |
N/A
|
|
処理ID |
実行された処理のIDです。 |
N/A
|
|
作成者のメールアドレス |
パイプラインを実行したユーザーのメールアドレスです。 |
N/A
|
|
Unixタイムスタンプ形式のデータ範囲の終了日時 |
パイプラインの実行が開始された日時です。 |
N/A
|
|
Unixタイムスタンプ形式のデータ範囲の開始日時 |
パイプラインの実行リクエストが送信された日時です。 |
N/A
|
|
Unixタイムスタンプ形式の処理作成日時 |
処理が作成された日時です。 |
N/A
|
|
無効なデータによりエクスポートが停止したか |
[データに無効な値がある場合、エクスポートを停止する]設定が有効で、エクスポート時にパイプラインに無効なデータが含まれている場合は「はい」、それ以外の場合は「いいえ」です。 |
TRUE/FALSE
|
|
処理の再実行回数 |
処理が再実行された回数です。 |
N/A
|
|
処理の種類 |
トリガーパイプラインを開始する処理の種類です:予約、手動、Webhook、バックフィル、Zoho Flow |
MANUAL,SCHEDULE,RELOAD,BACKFILL,WEBHOOK,ZOHO FLOW
|
パイプライン処理の完了をトリガー(パイプライン1)として設定した後、[パイプラインを実行する]をアクション(パイプライン2)として設定し、さらに[チャンネルにボットとしてメッセージを送信]をアクションとして設定します。
2. [パイプラインを実行する]をアクションとして設定
メモ:変数を挿入して、変数名やメッセージを作成できます。
DataPrepでは、フィルター条件に次の変数を使用できます。フィルター条件を設定するには、[例]列の値を使用します。N/A,と記載されている項目には、必要に応じて適切な値を指定してください。
|
変数
|
説明
|
例
|
|
組織ID |
パイプラインの組織ID。 |
N/A
|
|
ワークスペースID |
パイプラインのワークスペースID。 |
N/A
|
|
パイプラインID |
選択したパイプラインのID。 |
N/A
|
|
処理の実行ステータス |
処理が成功したか失敗したかを示すステータス。 |
FAILURE,RUNNING,SUCCESS,CREATED,SKIPPED |
|
Unixタイムスタンプ形式の処理完了日時 |
処理にかかった合計時間。 |
N/A
|
|
処理ID |
実行された処理のID。 |
N/A
|
|
作成者のメールアドレス |
パイプラインを実行するユーザーのメールアドレス |
N/A
|
|
Unixタイムスタンプ形式のデータの範囲の終了日時 |
パイプラインの実行が開始された日時。 |
N/A
|
|
Unixタイムスタンプ形式のデータの範囲の開始日時 |
パイプラインの実行がトリガーされた日時。 |
N/A
|
|
Unixタイムスタンプ形式の処理の作成日時 |
処理が作成された日時。 |
N/A
|
|
無効なデータが原因でエクスポートが停止しましたか? |
[データに無効な値がある場合はエクスポートを停止する]設定が有効で、エクスポート中にパイプラインに無効なデータが含まれている場合は「はい」、それ以外の場合は「いいえ」です。 |
TRUE/FALSE
|
|
処理の再実行回数 |
処理が再実行された回数。 |
N/A
|
|
処理の種類 |
操作を開始する処理の種類:予約、手動、Webhook、Zoho Flow、バックフィル。 |
MANUAL,SCHEDULE,RELOAD,BACKFILL,WEBHOOK,ZOHO FLOW
|
4. フローの保存と実行
Zoho Flowでは、フローが自動的に保存されます。上部のスライダーをクリックしてZoho Flowのフローを有効にし、実際のデータで動作させます。
パイプライン1が正常に完了すると、Zoho Flowによってパイプライン2が開始され、Zoho Cliqのチャンネルにメッセージが送信されます。
重要:フローの処理とトリガーに同じパイプラインを指定しないでください。パイプラインが繰り返し実行される原因になります。
a)[連携する]をクリックし、データ連携に名前を付けます。
b)[認証する]をクリックし、表示されるポップアップで承認します。
c)Zoho DataPrepアカウントがZoho Flowに連携されます。
d)データ連携を設定すると、変数名が自動入力されます。必要に応じて名前を編集できます。
e)ドロップダウンから、[組織ID]、[ワークスペースID]、および[パイプラインID]を選択します。
f)次の[フィルター条件]を使用して、フローをトリガーする条件を設定することもできます。設定後、[完了]をクリックします。
DataPrepでは、フィルター条件に次の変数を使用できます。[例]列の値を使用して、フィルター条件を設定できます。N/A,と記載された項目には、必要に応じて適切な値を指定してください。
|
変数
|
説明
|
例
|
|
組織ID |
パイプラインの組織IDです。 |
N/A
|
|
ワークスペースID |
パイプラインのワークスペースIDです。 |
N/A
|
|
パイプラインID |
パイプラインのIDです。 |
N/A
|
|
処理の実行ステータス |
処理の成功または失敗のステータスです。 |
FAILURE,RUNNING,SUCCESS,CREATED,SKIPPED
|
|
Unixタイムスタンプ形式の処理完了日時 |
処理にかかった合計時間です。 |
N/A
|
|
処理ID |
実行された処理のIDです。 |
N/A
|
|
作成者のメールアドレス |
パイプラインを実行したユーザーのメールアドレスです。 |
N/A
|
|
Unixタイムスタンプ形式のデータの範囲の終了日時 |
パイプラインの実行が開始された日時です。 |
N/A
|
|
Unixタイムスタンプ形式のデータの範囲の開始日時 |
パイプラインの実行がトリガーされた日時です。 |
N/A
|
|
Unixタイムスタンプ形式の処理作成日時 |
処理が作成された日時です。 |
N/A |
|
無効なデータが原因でエクスポートが停止しましたか? |
[データに無効な値がある場合、エクスポートを停止する]設定が有効で、エクスポート中にパイプラインに無効なデータが含まれていた場合は「はい」、それ以外の場合は「いいえ」です。 |
TRUE/FALSE
|
|
処理の再実行回数 |
処理が再実行された回数です。 |
N/A
|
|
処理の種類 |
パイプラインの実行をトリガーする処理の種類です:予約、手動、Webhook、バックフィル、Zoho Flow。 |
MANUAL,SCHEDULE,RELOAD,BACKFILL,WEBHOOK,ZOHO FLOW
|
g)たとえば、パイプライン処理が失敗したときに通知するには、[処理の実行ステータス]フィルターを使用し、失敗と入力します。