Click here to Skip to main content
65,938 articles
CodeProject is changing. Read more.
Articles / IoT

IoTHubTrigger Azure Function and Azure IoT Hub

5.00/5 (1 vote)
28 Dec 2018CPOL3 min read 9.3K  
IoTHubTrigger Azure Function and Azure IoT Hub

This article is an entry in our Microsoft Azure IoT Contest. Articles in this section are not required to be full articles so care should be taken when voting.

Table of Contents

Introduction

For the past few days, I have been playing with my MXChip and had written some articles about the same, you should be able to find those here. Here in this article, we will send some data to our Azure IoT hub and we will connect an Azure Function with our IoT Hub using IoTHubTrigger Event Hub Trigger Attribute. If you are ready, let’s do this.

Background

As I said, this article is part of my IoT article series, so if you have read my previous articles on this topic, it may be easier for you to understand the concept. Before you start this article, please make sure that you had already created an Azure IoT hub and it is running. You can always send the messages to this IoT Hub either by connecting the actual device, let’s say an MXChip or using a simulating device.

IoTHubTrigger Demo

Creating an Azure Function App

I am going to create an Azure Function App in Visual Studio, if you are not sure about how we can create and publish the Azure Function, please read this section of my previous article. Let’s create a new solution now.

Image 1

IoTHubTrigger

Once you click OK, a new Azure Function will be generated for you with some initial codes in it. Let’s edit the function as below:

C#
using Microsoft.Azure.EventHubs;
using Microsoft.Azure.WebJobs;
using Microsoft.Extensions.Logging;
using System.Text;
using IoTHubTrigger = Microsoft.Azure.WebJobs.EventHubTriggerAttribute;

namespace IoTHubTrigger_Azure_Function_and_Azure_IoT_Hub
{
    public static class IoTHubFunc
    {
        [FunctionName("IoTHubData")]
        public static void Run(
            [IoTHubTrigger("messages/events", Connection = "IoTHubTriggerConnection", 
            ConsumerGroup ="FuncGroup")]EventData message, 
            ILogger log)
        {
            log.LogInformation($"C# IoT Hub trigger function processed a message: 
            {Encoding.UTF8.GetString(message.Body.Array)}");
        }
    }
}

Here, the IoTHubTriggerConnection is the connection string we are providing in the local.settings.json file. The consumer group will come into play if you have many applications which need to be receiving the data from your IoT Hub. Below is the class definition of EventHubTriggerAttribute.

C#
public sealed class EventHubTriggerAttribute : Attribute
    {
        public EventHubTriggerAttribute(string eventHubName);

        public string EventHubName { get; }
        public string ConsumerGroup { get; set; }
        public string Connection { get; set; }
    }

Send Data to the Azure IoT Hub

As I mentioned earlier, there are two ways in which you can send the data to the Azure IoT Hub.

  1. Using a device, for example, MXChip
  2. Simulated device

Once the data is sending, you can see the message received count in Azure IoT Hub in the overview section.

Run the Azure Function

So, the IoT Hub has started receiving messages from the device, and now we can use our Azure Function to pull the data from the IoT hub with the help of IoT hub Trigger. Run your Function App, Simulated Device application and see the output.

Image 2

IoT Hub Trigger Output

As you can see in the output, our Azure Function app is receiving the data from Azure IoT hub instantly. Now you can perform any actions with this data. I will leave that to you.

Conclusion

Wow! Now we have learned:

  • Usage of Azure IoT Hub Trigger in Azure Function
  • Creating Azure Function App
  • See the Data from Azure IoT Hub in the Azure Function App

You can always ready my IoT articles here.

Your Turn. What Do You Think?

Thanks a lot for reading. Did I miss anything that you may think is needed in this article? Could you find this post useful? Kindly remember to share your feedback.

License

This article, along with any associated source code and files, is licensed under The Code Project Open License (CPOL)