Processors - Application Dependencies Code

Code

class lambdas.application_dependencies.ApplicationDependencies(config)[source]

Bases: object

product_queue_name = None
product_availability_queue_name = None
picks_table = None
ttl = None
__init__(config)[source]

This class will load all the dependencies needed for the application to run. This can cause exceptions if the configuration is not set up properly.

Parameters

config (Dictionary) – Contains key value pairs for configuration of the google tables

__load_dependencies(config)

Private Method to load all the dependencies of the application, sort of a dependency injection simulation :raises Exception:

get_bootstrap_server()[source]
get_kafka_masking_topic()[source]
get_kafka_capping_topic()[source]
get_product_dynamodb_table()[source]
get_masking_dynamodb_table()[source]
get_audit_dynamodb_table()[source]
get_bulk_dynamodb_table()[source]
get_product_queue_name()[source]
get_sqs_msg_limit()[source]
get_product_availability_queue_name()[source]
get_priority_two_queue_name()[source]
get_product_capping_queue_name()[source]
get_priority_one_queue_name()[source]