メイン コンテンツをスキップする 補完的コンテンツへスキップ

REST APIを呼び出してストリーミングUUIDを取得

Availability-note非推奨

このシナリオは、パイプラインでコネクターを簡単にセットアップして使用できるようにすることを目的としています。お使いの環境とユースケースに適応させてください。

以下の手順で作成されるパイプラインの例。

手順

  1. [Connections] (接続) > [Add connection] (接続を追加)をクリックします。
  2. 開いたパネルで、作成する接続のタイプを選択します。

    例

    REST HTTP BIN
  3. [Engine] (エンジン)リストでエンジンを選択します。
    情報メモ注:
    • データの高度処理の場合は、Cloud Engine for DesignではなくRemote Engine Gen2を使用することをお勧めします。
    • Talend Management Consoleから作成されたRemote Engine Gen2がないか、存在していても稼働中ではないステータスの場合は、リストで接続の[Connection type] (接続タイプ)を選択することも、新しい接続を保存することもできません。
    • 使用可能な接続タイプのリストは、選択したエンジンによって異なります。
  4. 作成する接続のタイプを選択します。
    ここではRESTを選択します。
  5. RESTプロパティの説明に従って、接続のプロパティとRESTサーバーのURLアドレスを入力し、目的の接続にチェックを入れ、[Add dataset] (データセットを追加)をクリックします。この例では、ランダムな汎用一意識別子(UUID)を返すhttps://httpbin.org APIサービスが呼び出されます。
    新しいREST接続の設定。
  6. [Add a new dataset] (新しいデータセットを追加)パネルで、データセットに名前を付けます。RESTコネクターが、ボディエントリーが解析されたJSONを返します。

    例

    UUID
  7. 必要なプロパティを入力してサービスを呼び出し、[View sample] (サンプルを表示)をクリックしてデータセットサンプルのプレビューを表示します。
    1. [Type] (タイプ)フィールドで[Streaming] (ストリーミング)を選択します。
    2. [Resource] (リソース)フィールドにuuidと入力し、https://httpbin.org APIサービスからuuidレコードを取得します。
    3. [HTTP method] (HTTPメソッド)フィールドで、GETを選択します。
    4. [Answer body format] (回答ボディの形式)フィールドで、JSONを選択します。
  8. [Validate] (検証)をクリックしてデータセットを保存します。
  9. 同じようにして、パイプラインでデスティネーションとして使うデータセットをTestという名前で追加し、ログを取得します。Test接続プロパティの説明に従って、接続のプロパティを入力します。
  10. [Pipelines] (パイプライン)ページで[Add pipeline] (パイプラインを追加)をクリックします。新しいパイプラインが開きます。
  11. パイプラインに意味のある名前を付けます。

    例

    Invoke REST API to get streaming UUIDs
  12. [ADD SOURCE] (ソースを追加)をクリックし、パネルが開いたら、UUIDというソースデータセットを選択します。Streamingというデータセットタイプを選択したので、パイプラインがストリーミングパイプラインに変わります。
  13. このソースデータセットの[Configuration] (設定)タブで、[Delay] (遅延)フィールドでAPIサービスをストリーミングするためのポーリング間隔を設定します。デフォルトは5000ms (ミリ秒)で、これによってデータは5秒おきに取得されます。
  14. パイプラインで[ADD DESTINATION] (デスティネーションを追加)アイテムをクリックしてパネルを開き、自分の出力ログの保存となる出力データセットを選択します。
  15. デスティネーションの[Configuration] (設定)タブで[Log records to STDOUT] (レコードをSTDOUTに記録)オプションを有効にし、この出力デスティネーションにログをキャプチャーします。
  16. [Save] (保存)をクリックして設定を保存します。
  17. Talend Cloud Pipeline Designerの上部ツールバーで[Run] (実行)ボタンをクリックするとパネルが開き、実行プロファイルを選択できるようになります。
  18. リストで実行プロファイルを選択し(詳細は実行プロファイルをご覧ください)、[Run] (実行)をクリックしてパイプラインを実行します。

タスクの結果

ストリーミングパイプラインは実行中となり、REST API サービスから呼び出されたデータが取得され、出力ログは更新時にさらに多くのUUIDを受信し続けます。上で定義されたようにUUIDが5秒ごとに取得されていることがわかります。
出力ログで5秒ごとに取得されるUUIDが強調表示されている状態。

このページは役に立ちましたか?

このページまたはコンテンツにタイポ、ステップの省略、技術的エラーなどの問題が見つかった場合はお知らせください。

こちらにフィードバックをお寄せください