データサービスタスクを作成 - Cloud

Talend Cloud Management Consoleユーザーガイド
Version
Cloud
Language
日本語
Product
Talend Cloud
Module
Talend Management Console
Content
デプロイメント > スケジューリング > タスクのスケジューリング
デプロイメント > デプロイ中 > タスクの実行
デプロイメント > デプロイ中 > パイプラインの実行
管理と監視 > プロジェクトの管理
管理と監視 > ユーザーの管理
Last publication date
2023-12-08
データサービスタスクとは実行可能な統合プロセスのことで、Talend Studioから公開されたサービスが含まれています。

始める前に

データサービスタスクを実行できるのは、マイクロサービスか Talend Runtime (OSGi)の実行プロファイルが設定されたRemote Engineのみです。

このタスクについて

データサービスのデプロイとアンデプロイは、ユーザーインターフェイスで手動で行うことができます。データサービスをスケジュール化したり、プランに追加したりすることはできません。このタイプのサービスは、オペレーターが明示的にアンデプロイするまで実行し続けます。

手順

  1. [Management] (管理)ページを開きます。
  2. [Tasks] (タスク)タブに移動します。
  3. ページの上部にあるファセット検索を使って環境とワークスペースを選択します。
  4. [Add task] (タスクを追加)をクリックします。
  5. [Data service] (データサービス)アーティファクトタイプを選択します。
  6. 実行するアーティファクトをドロップダウンリストから選択します。
    アーティファクトの詳細と説明が表示されます。
  7. タスクで使用するアーティファクトのバージョンを選択します。

    アーティファクトの新しいバージョンが公開されるたびにタスクを自動アップデートする場合は、[Always use the latest available artifact version] (アーティファクトの最新バージョンを常に使用)を選択します。必要であれば、特定のバージョンを選択して手動でアップデートすることもできます。

    アーティファクトの詳細と説明は自動的に更新されます。
  8. タスクのワークスペースを選択します。
  9. 新しいタスクに名前を付けます。
    デフォルトでは、作成元であるアーティファクトの名前がタスク名になります。
    注: ワークスペース内のタスクには一意名が必要です。
  10. オプション: タグをタスクに追加します。
    1. 既存のタグをドロップダウンリストから選択します。
    2. 名前を入力し、ドロップダウンリストでクリックして、新しいタグを作成します。
  11. オプション: タスクの説明を入力します。
  12. [Continue] (続行)をクリックします。
  13. [Parameters] (パラメーター)ステップで、データサービスのパラメーターに値を入力します。
    このステップで[Show order as in Studio] (Studioと同じように順序を表示)の切り替えが無効になっている場合、値を設定できるのはTalend Studioでparameter_プレフィックスを使って定義したパラメーターのみです。
    注: 値が特殊文字として解釈される場合(\tなど)は、\ではなく\\を使います。
  14. オプション: [Advanced parameters] (詳細パラメーター)ステップで、Talend Studioでプレフィックスなしで定義したパラメーター、およびデータサービスで定義されていないconnection_パラメーターに値を入力します。 このセクションは、[Show order as in Studio] (Studioと同じように順序を表示)の切り替えが無効になっている場合に利用できます。無効になっていない場合、パラメーターはすべて[Parameters] (パラメーター)ステップにあります。
    注: 値が特殊文字として解釈される場合(\tなど)は、\ではなく\\を使います。
  15. オプション: [Connections] (接続)ステップで、ドロップダウンリストから適切な接続形式を選択するか、アーティファクトで既に定義されているパラメーターに基づいて新しい接続を作成します。
  16. オプション: [Resources] (リソース)ステップで、タスクに使用する適切なリソースを選択します。
  17. [Processing] (処理)ステップで、タスクをデプロイする実行ランタイムを[Engine] (エンジン)ドロップダウンリストから選択します。
    オプション 説明
    Remote Engine データサービスとルートは、使用しているTalend Studioのバージョンと互換性があるRemote Engineでのみ実行できます。互換性マトリクスについては、Cloud EngineとTalend Remote Engineのアーテフィファクトの互換性をご覧ください。

    タスクの種類によっては、選択したRemote Engineに対応する実行プロファイルが必要となります。この実行プロファイルの設定は、そのエンジンの作成時か、[Edit engine] (エンジンを編集)ウィザード([Engines] (エンジン) > <RemoteEngineName> > [Edit] (編集) パス経由でアクセス可能)で行う必要があります。
    Remote Engineクラスター クラスターに割り当てられたRemote Engineはすべて同じバージョン(v2.8.4以降)であることが必要です。

    タスクの種類によっては、クラスター内のRemote Engineに適切なマイクロサービスか Talend Runtime (OSGi)実行プロファイルが設定されている必要があります。このエンジンは、使用されているアーティファクトのバージョンと互換性があることが必要です。
  18. オプション: Remote Engineやクラスターにマイクロサービスをデプロイする際に、実行プロファイルを選択します。

    タスク実行のJVMパラメーターは、選択したRemote Engineやクラスターのために以前作成した実行プロファイルを選択して設定できます。

    この機能はRemote Engine2.12.4以降でサポートされています。

  19. [Metric Path] (メトリクスパス)で、ランタイムでのリクエスト数など、メトリクスデータを取得するためにデプロイメント時に使用されるメトリクスパスを入力します。
    デフォルト値はアーティファクト名です。メトリックデータが[Task Details] (タスクの詳細)ページに表示されるようにするには、この値を変更しないでおくことをお勧めします。このフィールドが空の場合、このページにメトリック情報は表示されません。
    ヒント: 同じ名前のアーティファクトが複数のプロジェクトに存在し、同じTalend Remote Engine/ Talend Runtime上で実行するように設定されている場合は、プロジェクト名をアーティファクト名に追加できます。
  20. オプション: Remote Engineやクラスターにマイクロサービスをデプロイする時に[Run as impersonated user] (実行ユーザーとして実行)フィールドにユーザー名を入力すれば、別のユーザーとしてタスクを実行できます。
    この機能は、Unix (または同様の)環境にRemote Engineがインストールされている場合のみサポートされます。
    この機能はRemote Engine2.12.4以降でサポートされています。
    実行ユーザーの詳細は、Talend Remote Engineの実行ユーザー化を設定をご覧ください。
  21. マイクロサービスをデプロイする時は、ポートの割り当てを設定します。
    オプション 説明
    [Automatic] (自動) マイクロサービスのインスタンスが実行されるポートはシステムによって定義されています。
    [Custom] (カスタム) マイクロサービスの全インスタンスを実行する静的なポート番号を設定できるため、外部の負荷分散が容易になります。
  22. クラスターでタスクをデプロイするよう選択した場合は、デプロイメント戦略を選びます。
    オプション 説明
    [Parallel] (並列) クラスターの全Remote Engineにタスクを同時にデプロイします。
    [Rolling] (ローリング) クラスターのRemote Engineにタスクを1つずつデプロイします。
  23. 変更を保存します。
    [Deploy] (デプロイ)をクリックすると、[Task Details] (タスクの詳細)ページからタスクをデプロイできます。

タスクの結果

これで、Talend Cloud Management Consoleでタスクを実行できます。

注:

指数関数的なバックオフ再試行パターンを採用することで、1回目と2回目の再試行が高速化(最初の失敗からそれぞれ1分後と3分後)されるだけでなく、ピーク時の負荷急増の際にグローバルな動作が向上しました。

たとえば既に実行中のタスクを実行しようとすると、その実行は失敗します。 Talend Cloud Management Consoleは実行間隔を長くしながら再試行するので、最初の再試行は1分後、2回目は2分後、その後は4分後と8分後に行われます。

4回目の試行が失敗すると、Exceeded the limit of deployment attempts: another instance of the same task was running on the engine at same timeというエラーメッセージが表示されます。その場合は、後でタスクを実行し直してみてください。

例