Microservices Engine:時系列データの処理

手順

たとえば、ジョブは毎日 00:30 にトリガーされます。ジョブを使用して前日の 23:30 に更新されたデータを処理する場合、ジョブの時間オフセットを 1 時間に設定する必要があります。

1. エージェントを SchedulerX に接続し、時系列データを処理します。エージェントを SchedulerX に接続する方法の詳細については、クイックスタートのトピックを参照してください。

   public class TestHelloJob extends JavaProcessor {
   
       @Override
       public ProcessResult process(JobContext context) throws Exception {
           System.out.println("hello schedulerx2.0");
           // ジョブの実行時間を出力します
           System.out.println("dataTime=" + context.getDataTime().toString("yyyy-MM-dd HH:mm:ss"));
           return new ProcessResult(true);
       }
   
   }

2. SchedulerX コンソールでジョブを作成します。詳細については、「ジョブの作成」をご参照ください。時間オフセット時間オフセット[タイミング設定]タイミング構成 ウィザードページの -3600context.getDataTime() パラメーターを （1 時間）に設定します。単位：秒。ジョブは引き続き 00:30 にトリガーされます。ジョブがトリガーされると、ジョブは メソッドを使用して、前日の 23:30 に更新されたデータを取得します。

結果の確認

1. ジョブの作成後、[インスタンス]インスタンス ページに移動し、対応するジョブインスタンスを見つけて、詳細詳細[操作]操作 列の をクリックします。

2. [ジョブインスタンスの詳細]ジョブインスタンスの詳細 ページで、[基本情報]基本情報 をクリックします。

3. [基本情報]基本情報 タブで、[データ時間]データ時刻 の値が指定した値と同じであることを確認します。