如何使用 Quartz 调度程序维护作业历史记录

Question

我想维护由 Quartz 调度程序调度的作业的历史记录，其中包含以下属性：“开始时间”、“结束时间”、“成功”、“错误”。

有两个接口可用于此：ITriggerListener 和 IJobListener （我使用接口的 C# 命名约定，因为我使用的是 Quartz.NET，但同样的问题可能是要求 Java 版本）。

IJobListener 有一个 JobToBeExecuted 和一个 JobWasExecuted 方法。后者提供了一个JobExecutionException，以便您知道何时出现问题。但是，无法关联 JobToBeExecuted 和 JobWasExecuted。假设我的工作运行十分钟。我从 t0 和 t0+2 开始（因此它们重叠）。我收到两次对 JobToBeExecuted 的调用，并将两个开始时间插入到我的历史记录表中。当两个作业在 t1 和 t1+2 完成时，我收到两次对 JobWasExecuted 的调用。我如何知道在每次调用中要更新哪些数据库记录（以存储结束时间及其相应的开始时间）？

ITriggerListener 还有另一个问题。当作业失败时，无法在 TriggerComplete 方法内获取任何错误。

我如何获得所需的行为？

Answer 1

实现此目的的方法是在 JobToBeExecuted 中生成一个标识符，将其存储在 JobExecutionContext 中，并从 中的 JobExecutionContext 中再次检索它作业已执行。

public void JobToBeExecuted(JobExecutionContext context)
{
    // Insert history record and retrieve primary key of inserted record.
    long historyId = InsertHistoryRecord(...);
    context.Put("HistoryIdKey", historyId);
}

public void JobWasExecuted(JobExecutionContext context,
                           JobExecutionException jobException)
{
    // Retrieve history id from context and update history record.
    long historyId = (long) context.Get("HistoryIdKey");
    UpdateHistoryRecord(historyId, ...);
}

Answer 2

调度程序必须维护一个密钥，使其能够关联每个历史记录条目。必须在作业启动时创建某种唯一的作业 ID 才能完成此任务。

你没有提到这样的事情，所以我认为值得提出建议。

更新：当创建作业时，我会在数据库中插入一条记录并取回主键（可能是 GUID）。我会用它作为钥匙。

Answer 3

如果您愿意在最后更新数据库，则可以从 IJobExecutionContext 获取作业名称和运行时间：

public void JobWasExecuted(JobExecutionContext context,
                       JobExecutionException jobException)
{
    var sql = @"INSERT INTO MyJobAuditHistory 
                (JobKey, RunTime, Status, Exception) VALUES (?, ?, ?, ?)";

    // create command etc.
    command.Parameters.Add(context.JobDetail.Key.ToString());
    command.Parameters.Add(context.JobRunTime);
    command.Parameters.Add(jobException == null ? "Success" : "Fail");
    command.Parameters.Add(jobException == null ? null : jobException.Message);
}