はじめに
こちらの記事では、Workato の長時間実行アクション(Long Actions)には注意点があることをお伝えしました。
Workato には一定時間待つアクションが [scheduler by Workato] コネクターの [Wait for time duration] アクションとして用意されていますが、こちらは長時間実行アクションになっています。
単一のステップでは 90 秒でタイムアウトが発生するため、それ以上の時間に対応するためですが、待つ必要のある時間が 1 分程度の場合に長時間実行アクションの制限を回避する方法はないでしょうか？
実現方法
Python コネクターを利用することで、長時間実行アクションを使用せずに実現が可能です。
Ruby や JavaScript でも類似の機能は実現可能ですが、これらのコネクターはタイムアウト時間が 30 秒と通常のアクションより短いため、今回の用途では、タイムアウト時間が通常のアクションと同じ 90 秒の Python の方が向いています。
time モジュールの sleep メソッドを利用する
-
待ち時間の秒数をパラメータとして設定します
-
sleep 関数は time モジュールに含まれているため、time モジュールをインポートします
import time -
関数を定義し、time.sleep() を呼び出します
パラメータは文字列としてくることがあるため、int() でパラメータを整数に変換しておきます。def main(input): time.sleep(int(input["WaitSeconds"]))
Salesforce の Bulk API 2.0 のクエリでの使用例
一定時間待つ必要のある例として、Salesforce の Bulk API 2.0 のクエリを実行してみます。
Bulk API は、リクエストを投げた後、処理完了後に結果を取得する流れとなるため、ジョブを作成したのち、一定時間ごとにジョブの状態を確認し、ジョブの完了を待って結果を取得するという処理が必要となります。
Salesforce コネクターには長時間実行アクションとして提供されている [Search records in bulk using SOQL] があるため、実運用時はそちらを利用することをおすすめします。
-
カスタムアクションとして、Bulk API 2.0 のクエリジョブを作成します
ここでは Lead の情報を CSV 形式で取得します
-
ジョブの完了を待つため、[Repeat while] を利用します
-
先程作成した Python のアクションで 60 秒待ちます
-
カスタムアクションで、クエリジョブの状態を取得します
-
ジョブの状態が準備完了(UploadComplete)か処理中(InProgress)の間は、ループを継続するように設定します
-
ジョブの状態が正常終了の場合、カスタムアクションでクエリジョブの結果を取得します
-
ジョブの状態がそれ以外である場合、エラー終了します
-
テスト実行すると、正常終了し、ネットワークのデバッグ情報も取得できます。
まとめ
まとめると、以下のようになります。
- Workato のスケジューラの [Wait for time duration] アクションは長時間実行アクションのためレシピに制限が生じる
- 待ち時間が 1 分程度の場合は、Python コネクターを利用することで、通常のアクションとして実現可能
- Ruby, JavaScript コネクターはタイムアウト時間が他のアクションより短いため、待ち時間の設定には向いていない
おわりに
Workato の標準アクションを適用しにくいケースでは、Python や Ruby などのスクリプトを利用することで、より便利な方法で実現できる場合があります。
各スクリプトのコネクターによって、向き不向きがありますので、適切なコネクターを選ぶことが重要です。
Workatoの導入・導入後の活用などでお困りの場合、Workatoリセラーにご相談する方法もございます。お困りごとがございましたら、認定リセラーの日立ソリューションズへ是非ご相談ください。
参考リンク
- 株式会社 日立ソリューションズ
- Workato 公式サイト
- Python 公式サイト
- Salesforce 公式サイト
- 本記事のサンプルレシピ
- JPデータセンター利用者向け
- USデータセンター利用者向け