亚洲精品无码不卡在线播放,99热门精品一区二区三区无码,18禁午夜福利在线播放

阿里巴巴分布式任務調度系統SchedulerX 2.0提供日志服務，您無需修改代碼，只需增加一個Log4j或Logback的配置，即可在控制臺看到每次任務調度（包括分布式任務）的業務日志。本文介紹如何通過SchedulerX接入并查看日志服務。

前提條件

（可選）創建命名空間。
創建資源。
應用升級為專業版并開通日志服務。具體操作，請參見如何升級為專業版。
說明
開通日志服務后，當前日志最多可保留2周，超過2周的日志會被清理。

接入配置

升級SchedulerX客戶端版本

將SchedulerX客戶端版本升級到最新版本，客戶端最新版本，請參見客戶端發布記錄。以Spring Boot Starter為例，在應用程序的pom.xml文件中添加SchedulerxWorker依賴。

<dependency>
    <groupId>com.aliyun.schedulerx</groupId>
    <artifactId>schedulerx2-spring-boot-starter</artifactId>
    <version>${schedulerx最新版本}</version>  
</dependency>

配置Log Appender采集日志服務

Log4j2 Appender

方法一：單獨收集任務調度日志

該方法可以由業務自己控制，只將任務調度日志采集，其他業務代碼不會被采集，方便排查問題。

log4j2增加一個Appender和Logger如下：

<?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" />
        </Root>
        <Logger name="schedulerx" level="info" additivity="false">
            <AppenderRef ref="schedulerxLog" />
        </Logger>
    </Loggers>
</Configuration>

修改業務代碼如下，使用Logger: schedulerx采集任務調度的日志。

package com.hxm.test.processor;

import com.alibaba.schedulerx.worker.domain.JobContext;
import com.alibaba.schedulerx.worker.processor.JavaProcessor;
import com.alibaba.schedulerx.worker.processor.ProcessResult;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Component;


@Component
public class HelloWorldJob3 extends JavaProcessor {
    private static final Logger logger = LoggerFactory.getLogger("schedulerx");

    @Override
    public ProcessResult process(JobContext context) throws Exception {
        LOGGER.info("hello HelloWorldJob3");
        return new ProcessResult(true);
    }

}

方法二：搜集所有業務日志

該方法只需要配置Log4j文件，不需要修改一行業務代碼。如果將SchedulerxLog配置在rootLogger里，會讓所有日志都通過SchedulerX采集，不僅搜索速度較慢，而且業務日志和任務調度日志會混在一起，難以排查問題。配置如下：

<?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 Appender

方法一：單獨收集任務調度日志

log4j.properties增加一個Appender和Logger。

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

修改業務代碼如下，使用Logger: schedulerx采集任務調度的日志。

package com.hxm.test.processor;

import com.alibaba.schedulerx.worker.domain.JobContext;
import com.alibaba.schedulerx.worker.processor.JavaProcessor;
import com.alibaba.schedulerx.worker.processor.ProcessResult;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Component;


@Component
public class HelloWorldJob3 extends JavaProcessor {
    private static final Logger logger = LoggerFactory.getLogger("schedulerx");

    @Override
    public ProcessResult process(JobContext context) throws Exception {
        logger.info("hello HelloWorldJob3");
        return new ProcessResult(true);
    }

}

方法二：收集所有日志

log4j.properties增加一個Appender，將這個Appender配置在rootLogger里：

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

Logback Appender

說明

SchedulerxLogbackAppender這個類在依賴的SDK schedulerx2-worker JAR包里面，需要升級SchedulerX客戶端到最新版本。客戶端最新版本，請參見客戶端發布記錄。

方法一：單獨收集任務調度日志

logback.xml增加一個Appender和Logger。

<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" />
</root>

<logger name="schedulerx" level="INFO">
    <appender-ref ref="schedulerxLog"/>
</logger>

修改業務代碼如下，使用Logger: schedulerx采集任務調度的日志。

package com.hxm.test.processor;

import com.alibaba.schedulerx.worker.domain.JobContext;
import com.alibaba.schedulerx.worker.processor.JavaProcessor;
import com.alibaba.schedulerx.worker.processor.ProcessResult;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Component;


@Component
public class HelloWorldJob3 extends JavaProcessor {
    private static final Logger logger = LoggerFactory.getLogger("schedulerx");

    @Override
    public ProcessResult process(JobContext context) throws Exception {
        LOGGER.info("hello HelloWorldJob3");
        return new ProcessResult(true);
    }

}

方法二：收集所有日志

logback.xml增加一個Appender，將其配置在rootLogger里：

<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>

查看輸出的日志

登錄分布式任務調度平臺。
在左側導航欄單擊任務管理。
在任務列表中找到目標任務，在目標任務的操作列選擇更多 > 歷史記錄，進入到任務實例記錄頁面。
在任務實例記錄頁面，單擊目標任務操作列的日志。

日志中關鍵詞的定義如下：

ip: 打印該日志的執行機器。
executionId: 本次任務實例的執行ID，格式為${jobId}_${jobInstanceId}_${taskId}。
level: 日志的級別。
log：日志的信息。
throwable: 應用拋出異常時，會打印該字段。
time：打印日志的時間。

應用場景及演示

查詢業務失敗的原因

SchedulerX 2.0的日志服務可以收集任務的執行日志和異常，包括Service的日志都可以收集。

新建代碼。

新建任務代碼，配置使用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 {
    /**使用SchedulerX收集日志**/
    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);
    }

}

新建Service業務代碼，配置使用SchedulerX打印日志。

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 {
    /**使用SchedulerX收集日志**/
    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;
    }

}

控制臺配置任務。
根據代碼邏輯可知1除以0肯定會拋出異常。
任務運行一次后，通過任務實例列表查看日志。
根據日志內容，可得出失敗的原因是TestServiceImpl拋出了除0的異常。

查詢分布式任務失敗原因

SchedulerX 2.0的分布式任務用來執行批量任務，例如某個任務批次執行失敗了，您想查詢具體是哪個子任務失敗時，可執行如下操作：

新建任務代碼，配置使用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);
    }
}

控制臺配置任務并執行一次。
查看日志。具體操作，請參見查看輸出的日志。
在日志中搜索關鍵字，快速定位失敗的任務及原因。

根據關鍵字查詢歷史日志

任務實例的歷史記錄只保留最近60條。如果想排查歷史上任務失敗的原因，可以通過控制臺左側導航欄的日志查詢來檢索。日志查詢支持根據任務ID、關鍵字和時間區間搜索。

示例Demo

Log4j2 Demo下載地址：https://schedulerx2.oss-cn-hangzhou.aliyuncs.com/examples/schedulerx-example-log-log4j2.tar.gz
Logback Demo下載地址：https://schedulerx2.oss-cn-hangzhou.aliyuncs.com/examples/schedulerx-example-log-logback.tar.gz

日本熟妇hd丰满老熟妇,中文字幕一区二区三区在线不卡 ,亚洲成片在线观看,免费女同在线一区二区

如何接入日志服務

前提條件

接入配置

升級SchedulerX客戶端版本

配置Log Appender采集日志服務

Log4j2 Appender

Log4j Appender

Logback Appender

查看輸出的日志

應用場景及演示

查詢業務失敗的原因

查詢分布式任務失敗原因

根據關鍵字查詢歷史日志

示例Demo