BackpackDispatcher

class sasquatchbackpack.sasquatch.BackpackDispatcher(source, redis_address='default')

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

• redis_address (str, default: 'default')

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.

Return type:

tuple[str, list]

Returns:

• response-text (str) – The results of the POST request in string format

• records (list) – List of earthquakes with those already stored on remote removed