能否让Azure持续运行的Web Job A查询队列，判断Job B是否在1小时内执行过指定账户任务？

你想直接查询Web Job队列来获取Job B的执行历史？其实这条路走不通——因为触发式Web Job使用的队列（比如你的triggeredqueue）只存储待处理的消息：一旦Job B成功处理完某条消息，这条消息就会从队列中被移除；如果处理失败，消息会暂时隐藏一段时间后重试，但最终还是会被删除。队列的设计目的是传递待执行任务，而不是保存历史执行记录。

要实现“过去一小时内该账户的Job B未执行”这个条件，最可靠的方式是让Job B在每次执行完成后，把执行记录存到一个持久化存储里（比如Azure Table Storage、SQL数据库都可以），然后Job A在触发前先查这个存储，判断是否满足条件。

下面是具体的实现方案：

第一步：让Job B记录执行历史 #

修改Job B的代码，每次处理完账户任务后，把AccountId和执行时间写入Azure Table Storage——Table Storage轻量、成本低，非常适合存这种结构化的小记录：

public class Functions 
{ 
    public static void ProcessQueueMessage([QueueTrigger("triggeredqueue")] string message, TextWriter log) 
    { 
        var accountId = message; 
        // 先执行你的业务逻辑
        // DO STUFF WITH accountId HERE...

        // 把执行记录写入Table Storage
        CloudStorageAccount storageAccount = CloudStorageAccount.Parse(ConnectionStringHelper.StorageConnectionString);
        CloudTableClient tableClient = storageAccount.CreateCloudTableClient();
        CloudTable executionTable = tableClient.GetTableReference("JobBExecutions");
        executionTable.CreateIfNotExists();

        // 创建执行记录实体
        var executionRecord = new JobBExecution(accountId)
        {
            ExecutionTime = DateTime.UtcNow
        };
        var insertOp = TableOperation.InsertOrReplace(executionRecord);
        executionTable.Execute(insertOp);
    }
}

// 定义Table Storage的实体类
public class JobBExecution : TableEntity
{
    // 构造函数：用AccountId作为分区键，方便后续查询
    public JobBExecution(string accountId)
    {
        PartitionKey = accountId;
        RowKey = Guid.NewGuid().ToString(); // 保证每条记录唯一
    }

    // Table Storage需要无参构造函数
    public JobBExecution() { }

    public DateTime ExecutionTime { get; set; }
}

第二步：让Job A查询执行历史 #

修改Job A的代码，在触发Job B之前，先去Table Storage里查该账户最近一小时有没有执行记录：

class Program 
{ 
    static void Main() 
    { 
        while (true) 
        { 
            var accounts = getAccounts(); 
            foreach (var account in accounts) 
            { 
                if (testOtherBusinessLogic(account)) 
                { 
                    // 先检查该账户的Job B是否在过去一小时内执行过
                    if (!DidJobBRunForAccountInLastHour(account.AccountId))
                    {
                        // 满足条件，才添加队列消息触发Job B
                        CloudStorageAccount storageAccount = CloudStorageAccount.Parse(ConnectionStringHelper.StorageConnectionString);
                        CloudQueueClient queueClient = storageAccount.CreateCloudQueueClient();
                        CloudQueue queue = queueClient.GetQueueReference("triggeredqueue");
                        queue.CreateIfNotExists(); 

                        CloudQueueMessage message = new CloudQueueMessage(account.AccountId); 
                        queue.AddMessage(message); 
                    }
                } 
            } 
            System.Threading.Thread.Sleep(7000); 
        } 
    } 

    // 新增的查询方法：检查账户最近一小时的执行记录
    private static bool DidJobBRunForAccountInLastHour(string accountId)
    {
        CloudStorageAccount storageAccount = CloudStorageAccount.Parse(ConnectionStringHelper.StorageConnectionString);
        CloudTableClient tableClient = storageAccount.CreateCloudTableClient();
        CloudTable executionTable = tableClient.GetTableReference("JobBExecutions");
        executionTable.CreateIfNotExists();

        // 构建查询：找该账户、且执行时间在一小时内的记录
        var query = new TableQuery<JobBExecution>()
            .Where(
                TableQuery.GenerateFilterCondition("PartitionKey", QueryComparisons.Equal, accountId)
                + " and " + 
                TableQuery.GenerateFilterConditionForDate("ExecutionTime", QueryComparisons.GreaterThanOrEqual, DateTime.UtcNow.AddHours(-1))
            );

        // 查询并判断是否有结果
        var recentExecutions = executionTable.ExecuteQuery(query).ToList();
        return recentExecutions.Any();
    }
}

一些额外的优化建议 #

• 清理旧记录：可以定期清理Table Storage里超过7天（或你需要的时长）的执行记录，避免存储量越来越大——可以写个定时的小Web Job或者Azure Function来做这件事。
• 用UTC时间：代码里统一用DateTime.UtcNow，不要用本地时间，避免时区差异导致判断出错。
• 避免重复触发：如果Job A有多个实例在运行，可能会出现同时触发同一个账户Job B的情况。可以给队列消息设置VisibilityTimeout，或者在Table Storage里用乐观并发控制来避免重复执行。

内容的提问来源于stack exchange，提问作者Matt Spinks