Azure IoT Hub / Azure Event Hub input plugin

[R290]

Feature Request

Proposal:

The proposal is to develop a plugin, which could be as simple as building a wrapper for azure-event-hubs-go. I currently have a proof of principle plugin conforming to the telegraf.ServiceInput interface. In the future I'm planning to add metric tracking and a configurable persistent receiver offset (so each message is received once).

Current behavior:

No Azure IoT Hub or Azure Event Hub input plugin is currently present in Telegraf.
Development on the AMQP 1.0 plugin seems to have stagnated.

Desired behavior:

Configurable plugin for Azure IoT Hub and Azure Event Hub.

Use case: [Why is this important (helps with prioritizing requests)]

This plugin would allow telegraf and the rest of the TICK-stack to be used as backend for IoT applications and other Azure services. Azure itself does offer a similar service (Time Series Insights), but in my specific use case there is a strong preference for using the TICK-stack.

Implementation:

I'd be willing to put in the time and effort to mature the proof of principle. Some feedback might be needed since I'm pretty to new to Go and programming a backend in general.

[danielnelson]

This would be great to have. I do have some reservations about some dependencies as they appear fairly new, would be interested to see how our Gopkg.lock looks with your proof of concept code.

[R290]

This is my Gopkg.lock after dep ensure -vendor-only (including #5259 and my changes):

Gopkg.lock.txt

As far as I can see the new dependencies are:

• github.com/Azure/azure-amqp-common-go
• github.com/Azure/azure-event-hubs-go
• github.com/Azure/azure-sdk-for-go
• github.com/jpillora/backoff
• pack.ag/amqp

dep version output:

dep:
version : v0.5.0
build date : 2018-07-26
git hash : 224a564
go version : go1.10.3
go compiler : gc
platform : linux/amd64
features : ImportDuringSolve=false

[R290]

PR is merged, so closing this issue. In the future a new issue might be opened for a generic AMQP 1.0 consumer with Azure IoT Hub / Azure Event Hubs configuration options.