Switch branches/tags
Nothing to show
Find file History
Fetching latest commit…
Cannot retrieve the latest commit at this time.
Permalink
..
Failed to load latest commit information.
lib/logstash/inputs
spec/inputs
CHANGELOG.md
Gemfile
LICENSE
README.md
Rakefile
logstash-input-azuretopicthreadable.gemspec

README.md

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_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.

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 when topic is empty. The default value is 1/50.

Examples

input
{
    azuretopicthreadable
    {
        namespace => "mysbns"
        access_key_name => "mySASkeyname"
        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.