Azure Function - Queue Monitor (v1)

FunctionV1.csx

#r "Microsoft.WindowsAzure.Storage"

using System;
using Microsoft.WindowsAzure.Storage;

public static void Run(TimerInfo myTimer, TraceWriter log)
{
    log.Info($"C# Timer trigger function executed at: {DateTime.Now}");

    // connect to Azure Storage
    var connectionString = System.Configuration.ConfigurationManager.AppSettings["AzureWebJobsStorage"];
    var account = CloudStorageAccount.Parse(connectionString);
    var queueClient = account.CreateCloudQueueClient();

    // check the length of each queue
    var queueNames = new string[] { "processorders", "processorders-poison" };
    foreach (var queueName in queueNames)
    {
        // get a reference to the queue and retrieve the queue length
        var queue = queueClient.GetQueueReference(queueName);
        queue.FetchAttributes();
        var length = queue.ApproximateMessageCount;

        // log the length
        log.Info($"{queueName}: {length}");
    }
}