BackpackDispatcher

class sasquatchbackpack.sasquatch.BackpackDispatcher(source, config)

Bases: object

A class to send backpack data to kafka.

Parameters:

• source (DataSource) – DataSource containing schema and record data to be posted to remote

• config (DispatcherConfig) – Item that transmits other relevant information to the Dispatcher

Methods Summary

create_topic()	Create kafka topic based off data from provided source.
post()	Assemble schema and payload from the given source, then makes a POST request to kafka.

Methods Documentation

create_topic()

Create kafka topic based off data from provided source.

Returns:

response text – The results of the requests in string format

Return type:

str

post()

Assemble schema and payload from the given source, then makes a POST request to kafka.

Returns:

response text – The results of the POST request in string format

Return type:

str