...

/

Solution Review: Applying a Queue Trigger

Solution Review: Applying a Queue Trigger

Review the solution of using a queue trigger to schedule a job.

We'll cover the following...

Overview

The complete solution is presented in the code widget below:

using Microsoft.AspNetCore.Http;
using Microsoft.AspNetCore.Mvc;
using Microsoft.Azure.WebJobs;
using Microsoft.Azure.WebJobs.Extensions.Http;
using Microsoft.Extensions.Logging;
using Newtonsoft.Json;
using System;
using System.IO;
using System.Net;
using System.Threading.Tasks;

namespace StorageQueueTriggerDemo
{
    public class Functions
    {
        [FunctionName("JobTrigger")]
        [return: Queue("job-queue")]
        public static async Task<string> TriggerJob(
            [HttpTrigger(AuthorizationLevel.Anonymous, "get", "post", Route = null)] HttpRequest req,
            ILogger log)
        {
            string jobName = req.Query["jobName"];

            var requestBody = await new StreamReader(req.Body).ReadToEndAsync();
            dynamic data = JsonConvert.DeserializeObject(requestBody);
            jobName = jobName ?? data?.jobName;

            if (string.IsNullOrWhiteSpace(jobName))
                return null;

            return jobName;
        }

        [FunctionName("JobExecutor")]
        public void ExecuteJob([QueueTrigger("job-queue", Connection = "AzureWebJobsStorage")] string item, ILogger log)
        {
            Console.WriteLine($"The following job is scheduled: {item}");
        }
    }
}
The solution to putting a message on a storage queue from an HTTP trigger

Solving the challenge

First, we bind the return value of the ...