ポーリング監視イベントフローを構築する

開始する前に

• Okta Workflowsにアクセスできるスーパー管理者でなければなりません。

• コネクターをまだ作成していないときは、次の手順に従って作成します。

  • Okta Workflowsコンソールでコネクタービルダーコンソールのリンクを開きます。

  • コネクタービルダーでアイコンをクリックしてコネクターを作成します。新しいコネクターに一意の名前と有用な説明を付けます。

• コネクターに、基本的なことからすぐに始めるセクションのタスクで基本的な基盤と認証要素があることを確認してください。

手順

1. 新しいコネクターのフロー（Flows）タブで、新規フロー（+ New Flow）をクリックしてフローを作成します。

2. イベントを追加（Add Event）（Add event）をクリックします。イベント（Events）の選択肢から、ポーリング監視（Polling Monitor）を選択します。

   カーソル（Cursor）および返答出力（Return Outputs）フロー制御関数カードがフローに自動的に追加されます。例にある初期状態を参照してください。

3. オプションの追加（Add Options）をクリックして、ポーリング監視（Polling Monitor）カードのオプションを宣言します。

4. ポーリング監視イベントフローによって返される出力グループとフィールドを構成するには、返答出力（Add Outputs）カードの出力の追加（Add Outputs）（Return Outputs）をクリックします。

   1. ポーリング監視イベントには常にアクティブな実行モードがあるため、実行モードを有効化（Enable run mode）トグルは自動的に有効になり、変更できません。ポーリング監視の実行モードを有効化するを参照してください。

   2. 出力（Outputs）ダイアログでは、ポーリング監視が返す出力値を指定できます。グループの追加（Add group）をクリックして出力グループを作成し、フィールドの追加（Add Field）をクリックしてグループに各フィールドを追加します。返答出力がオブジェクトである場合、グループはオブジェクト内の最上位のキーと値のペアを形成し、フィールドは第2レベルのキーと値のペアを形成します。

      

   3. 適用（Apply）をクリックして、返答出力（Return Outputs）カードへの変更を保存します。

5. ポーリング監視フローを構築する：

   1. 日時（Date & Time） Now関数カードを追加して、endAtフィールドに新しい値を生成します。これは、APIクエリのフィルターとしてタイムスタンプを使用していることを前提としています。

   2. startAtおよびendAtクエリフィルターを使用して、HTTP呼び出しのクエリフィルターを構築します。ポーリング監視（Polling Monitor）イベントカードのカーソル（Cursor）出力をstartAt日付の入力としてドラッグします。

      カーソルがタイムスタンプではなくオブジェクトである場合は、オブジェクト（Object） Getカードを使用して、カーソルオブジェクトからタイムスタンプを取得します。

   3. フロー呼び出し（Call Flow）カードを追加して、接続の既存のhttpHelperフローを実行し、リモートサービスのAPIを呼び出します。

      • 作成したクエリフィルターをフロー呼び出し（Call Flow）カードのクエリ（query）フィールドの入力としてドラッグします。

      • ポーリング監視（Auth）イベントカードの認証（Auth）（Polling Monitor）フィールドで定義された接続を使用します。

   4. カーソル（Cursor）カードのプロパティー入力を使用して、新しいNow値を次回のスケジュールされた実行のカーソルとして保存します。これにより、元のカーソル（Cursor）値が上書きされます。

      • カーソルがタイムスタンプではなくオブジェクトである場合は、オブジェクト（Object） Constructカードを使用して、カーソルオブジェクト内のタイムスタンプを更新します。

      • コネクタの展開後、この ポーリング モニター（Polling Monitor）イベントカードを使用するアクティブな外部フローごとに、一意のカーソル値が保持されます。

   5. API呼び出しからのペイロード応答をオブジェクトのリストにフォーマットします。各オブジェクトには、グループの最上位レベルのキーと、グループフィールドの第2レベルのキーが含まれます。

   6. フォーマットされたAPI応答を返答出力（Return Outputs）カードのリスト（List）フィールドにマッピングします。

6. 保存（Save）をクリックし、フローに名前を付けます。

例

このポーリング監視フローの例では、カーソルオブジェクトを使用してタイムスタンプを保存し、リモートサービスに追加された新しいユーザーに関する情報を記録します。

これは、ポーリング監視（Polling Monitor）イベントカードを作成するときの初期ビューです。これには、ポーリング監視（Polling Monitor）イベントカードと、フロー制御（Flow Control）のカーソル（Cursor）および 返答出力（Return Outputs）カードが含まれています。

このポーリング監視イベントフローの構築方法の詳細を次に示します。

1. ポーリング監視（Polling Monitor）イベントカードでは、カーソルにタイムスタンプに加えてレコード情報も含まれるため、カーソル（Cursor）フィールドのタイプはObjectになります。

2. オブジェクト（Object） Get関数カードは、カーソルオブジェクトからタイムスタンプを取得します。これは、cursor_valueというキーに格納されています。

   この例では、カードの出力は、saved start dateというタイプの日時（Date & Time）フィールドです。

3. 日時（Date & Time） Nowカードは、ポーリング監視のこの実行に対して新しいタイムスタンプを生成します。便宜上、フィールド名はdate - New end dateに編集されます。

4. saved start dateとdate - New end dateフィールドは、Object Constructカードに結合され、outputというクエリオブジェクトを作成します。

5. フロー制御（Flow Control）のフロー呼び出し（Call Flow）カードは外部APIを呼び出します。コネクターにはhttpHelperフローと、/v1/usersエンドポイントへのGET呼び出しを使用します。

   時間枠でレコードを選択するための APIクエリフィルターを構築します。たとえば、1 か月間のユーザー作成イベントをチェックするクエリオブジェクトを次に示します。

   {
     "createdBefore": 2025-02-01T00:00:00.000Z,
     "createdAfter": 2025-01-01T00:00:00.000Z
   }

   フロー制御（Flow Control）Call Flowカードは接続認可のポーリング監視（Polling Monitor）カードで提供される接続（Connection）を使用します。

   この例では、このカードはnewUsersListというオブジェクトのリストを返します。

6. ステップ4と5のカードは、ブランチング（Branching） If Errorカードの試す（Try）ブロックで囲まれています。

   API呼び出しが成功した場合、試す（Try）カードの出力は新規ユーザーのリストになります。このオブジェクトのリストは、返答出力（Return Outputs）カードに送信されます。

   この関数のIf Errorブロックは表示されません。ただし、カーソルオブジェクトの設定時またはAPI呼び出し時に発生したエラーを処理するプロセスを指定します。

7. オブジェクト（Object） Constructカードはカーソルオブジェクトを更新します。cursor_valueキーに保存されている以前のタイムスタンプ値をdate - New end date値と置き換えます。これは最新のタイムスタンプを表し、ポーリング監視の次の反復処理ではsaved start dateフィールドにその値が使用されます。

8. フロー制御（Flow Control）のCursorカードは、この特定のユーザーのポーリング監視フローカーソルの プロパティー（Properties）値を更新します。

9. 返答出力（Return Outputs）カードは、ポーリング監視を呼び出したフローに新しいユーザーのリストを返し、この特定の実行を完了します。

次の手順

フローをテストする

フローをデプロイする