Microservices Engine:Simple Log Service と SchedulerX 2.0 の連携

Log4j 2

<?xml version="1.0" encoding="UTF-8"?>
<Configuration status="off">
    <Appenders>
        <Console name="Console" target="SYSTEM_OUT">
            <PatternLayout
                pattern="%d{yyyy-MM-dd HH:mm:ss.SSS} [%t] %-5level %logger{36} - %m%n" />
        </Console>
        <SchedulerxLog4j2Appender name="schedulerxLog"
            timeFormat="yyyy-MM-dd'T'HH:mmZ"
            timeZone="UTC"
            ignoreExceptions="true">
            <PatternLayout pattern="%d %-5level [%thread] %logger{0}: %msg"/>
        </SchedulerxLog4j2Appender>
    </Appenders>

    <Loggers>
        <Root level="info">
            <AppenderRef ref="Console" />
            <AppenderRef ref="schedulerxLog" />
        </Root>
    </Loggers>
</Configuration>

Log4j

log4j.rootLogger = INFO,console,schedulerxLog
log4j.appender.schedulerxLog=com.alibaba.schedulerx.worker.log.appender.SchedulerxLog4jAppender

Logback

<appender name="schedulerxLog" class="com.alibaba.schedulerx.worker.log.appender.SchedulerxLogbackAppender">
    <timeFormat>yyyy-MM-dd'T'HH:mmZ</timeFormat>
    <timeZone>UTC</timeZone>
</appender>

<root level="INFO">
    <appender-ref ref="CONSOLE" />
    <appender-ref ref="schedulerxLog"/>
</root>

ログフィールド

各ログエントリには次のフィールドが含まれます。

履歴ログのクエリ

SchedulerX は、各ジョブインスタンスについて最新の実行レコードのみ 60 件を保持します。古いレコードを検索するには、SchedulerX コンソールの左側のナビゲーションウィンドウで [ログクエリ] をクリックします。[ログクエリ] ページで、ジョブID、キーワード、または期間でフィルター処理します。

サービス障害の診断

Simple Log Service を統合した後、SchedulerX はジョブログとサービスログの両方 (例外を含む) を収集します。次の例は、サービス呼び出しにおけるゼロ除算エラーを特定する方法を示しています。

1. サービスメソッドを呼び出し、schedulerx ロガーでログを記録するジョブを作成します。

   package com.hxm.test.processor;
   
   import com.alibaba.schedulerx.test.service.TestService;
   import com.alibaba.schedulerx.worker.domain.JobContext;
   import com.alibaba.schedulerx.worker.processor.JavaProcessor;
   import com.alibaba.schedulerx.worker.processor.ProcessResult;
   
   import org.apache.logging.log4j.LogManager;
   import org.apache.logging.log4j.Logger;
   import org.springframework.beans.factory.annotation.Autowired;
   import org.springframework.stereotype.Component;
   
   @Component
   public class HelloWorldJob extends JavaProcessor {
       // Use the schedulerx logger to collect logs
       private static final Logger LOGGER = LogManager.getLogger("schedulerx");
   
       @Autowired
       private TestService testService;
   
       @Override
       public ProcessResult process(JobContext context) throws Exception {
           String parameters = context.getJobParameters();
           String tokens[] = parameters.split(" ");
           int a = Integer.valueOf(tokens[0]);
           int b = Integer.valueOf(tokens[1]);
           int c = testService.doDivision(a, b);
           LOGGER.info("testService.doDivision finished, a={}, b={}, c={}", a, b, c);
           if (c < 0) {
               return new ProcessResult(false, "result=" + c);
           }
           return new ProcessResult(true);
       }
   
   }

2. サービス用のクラスを作成します。

   package com.hxm.test.service;
   
   import org.apache.logging.log4j.LogManager;
   import org.apache.logging.log4j.Logger;
   import org.springframework.stereotype.Service;
   
   @Service("testService")
   public class TestServiceImpl implements TestService {
       // Use the schedulerx logger to collect logs
       private static final Logger LOGGER = LogManager.getLogger("schedulerx");
   
       @Override
       public int doDivision(int a, int b) {
           try {
                LOGGER.info("start to do division c = " + a + "/" + b);
                int c = a/b;
                LOGGER.info("c=" + c);
                return c;
           } catch (Exception e) {
               LOGGER.error("", e);
           }
           return -1;
       }
   
   }

3. SchedulerX コンソールでジョブを構成します。たとえば、ジョブパラメーターを 1 0 に設定してゼロ除算エラーをトリガーします。

   

4. タスクを一度実行してから、 [タスクインスタンスレコード] パネルを開いてログを表示します。 ログには、 TestServiceImpl が「ゼロ除算」例外をスローしたため、タスクが失敗したと表示されます。

   

分散ジョブ障害の診断

SchedulerX 2.0 の分散ジョブは、バッチ処理のために複数のワーカーにサブタスクをディスパッチします。サブタスクが失敗した場合、ログを使用して、どの特定のタスクが失敗したか、およびその原因を特定します。

1. サブタスクをディスパッチし、schedulerx ロガーでログを記録する分散ジョブを作成します。

   package com.hxm.test.processor;
   
   import java.util.ArrayList;
   import java.util.List;
   
   import com.alibaba.schedulerx.worker.domain.JobContext;
   import com.alibaba.schedulerx.worker.processor.MapJobProcessor;
   import com.alibaba.schedulerx.worker.processor.ProcessResult;
   
   import org.apache.logging.log4j.LogManager;
   import org.apache.logging.log4j.Logger;
   
   public class TestMapJobProcessor extends MapJobProcessor {
       private static final Logger LOGGER = LogManager.getLogger("schedulerx");
   
       @Override
       public ProcessResult process(JobContext context) throws Exception {
           String taskName = context.getTaskName();
           String parameter = context.getJobParameters();
           int dispatchNum = Integer.valueOf(parameter);
           if (isRootTask(context)) {
               LOGGER.info("start root task");
               List<String> msgList = new ArrayList<>();
               for (int i = 0; i <= dispatchNum; i++) {
                   msgList.add("msg_" + i);
               }
   
               return map(msgList, "Level1Dispatch");
           } else if (taskName.equals("Level1Dispatch")) {
               String task = (String)context.getTask();
               if (task.equals("msg_23")) {
                   LOGGER.error("msg={}, failed", task);
                   return new ProcessResult(false);
               } else {
                   LOGGER.info("msg={}, success", task);
               }
               return new ProcessResult(true);
           }
           return new ProcessResult(false);
       }
   }

2. SchedulerX コンソールでジョブを構成し、トリガーします。

   

3. ジョブログの表示で説明されているように、ジョブログを開きます。

4. キーワード (例: failed または error) を検索して、失敗したサブタスクとその原因を特定します。