DataSource

class sasquatchbackpack.sasquatch.DataSource(topic_name, *, uses_redis)

Bases: ABC

Base class for all relevant backpack data sources.

Parameters:

• topic_name (str) – Specific source name, used as an identifier

• uses_redis (bool)

Methods Summary

assemble_schema(namespace[, records])
get_records()
get_redis_key(datapoint)

Methods Documentation

abstract assemble_schema(namespace, records=None)

Parameters:

• namespace (str)

• records (dict | None, default: None)

Return type:

AvroBaseModel

abstract get_records()

Return type:

list[dict]

abstract get_redis_key(datapoint)

Parameters:

datapoint (dict)

Return type:

str