Introduction

This library is the companion to netbox-kafka-producer, making it easy to consume NetBox changes from Kafka.

Installation

pip install netbox-kafka-consumer

Synopsis

import netbox_kafka_consumer
import pynetbox

api = pynetbox.api('https://netbox', token='<token>')

bus = netbox_kafka_consumer.Client(
    api     = api,
    group   = '<kafka_consumer_group>',
    servers = '<kafka_servers>',
)

@bus.match(['Device', 'VirtualMachine'], 'delete')
def system_delete(record, request):
    print('System {} has been deleted by {}.'.format(record.name, request['user']))

bus.poll()

Subscriptions

Messages are matched by the class of record and type of event. In Django signal terms, the class is equivalent to the signal sender. As class is a reserved keyword, sender is used instead.

Callbacks are registered with the client, and the callback is called for each matching message. Either the subscribe method can be called directly, or the match decorator may be used.

Filters may be one of the following types.

For each matching callback, the function signature is inspected, and the name of each parameter determines the value of each argument. The following parameter names are supported.