Logstash input plugin for Azure Service Bus Topics

Summary

This plugin reads messages from Azure Service Bus Topics.

Installation

You can install this plugin using the Logstash "plugin" or "logstash-plugin" (for newer versions of Logstash) command:

logstash-plugin install logstash-input-azuretopic

For more information, see Logstash reference Working with plugins.

Configuration

Required Parameters

namespace

The Service Bus namespace.

access_key_name

Optional: The SAS policy name to the Service Bus resource. If undefined, plugin will assume ACS is used.

access_key

The access key to the Service Bus resource. Can be SAS policy or ACS key.

subscription

The name of the Topic Subscription.

topic

The name of the Topic.

Optional Parameters

deliverycount

Specifies the number of times to try (and retry) to process a message before the message shall be deleted. The default value is 10.

Examples

Using ACS:

input
{
    azuretopic
    {
        namespace => "mysbns"
        access_key => "VGhpcyBpcyBhIGZha2Uga2V5Lg=="
        subscription => "mytopicsubscription"
        topic => "mytopic"
    }
}

Using SAS Policy:

input
{
    azuretopic
    {
        namespace => "mysbns"
        access_key_name => "mySASkeyname"
        access_key => "VGhpcyBpcyBhIGZha2Uga2V5Lg=="
        subscription => "mytopicsubscription"
        topic => "mytopic"
    }
}

More information

The source code of this plugin is hosted in GitHub repo Microsoft Azure Diagnostics with ELK. We welcome you to provide feedback and/or contribute to the project.