Logstash input plugin for Azure Service Bus Topics

Summary

This plugin reads messages from Azure Service Bus Topics using multiple threads.

Installation

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

logstash-plugin install logstash-input-azuretopicthreadable

For more information, see Logstash reference Working with plugins.

Configuration

Required Parameters

namespace

The Service Bus namespace.

access_key

The access key to the Service Bus resource.

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.

threads

Specifies the number of threads to use to read the messages. The default value is 1.

thread_sleep_time

Specifies the number of seconds each thread should sleep before starting another loop of processing. The default value is 1/50.

Examples

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

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.