congress.datasources.json_ingester.json_ingester module

class congress.datasources.json_ingester.json_ingester.JsonIngester(name, config, exec_manager)

Bases: congress.datasources.datasource_driver.PollingDataSourceDriver

add_update_method(method, table_name)

get_row_data(table_id, *args, **kwargs)

Gets row data for a give table.

get_snapshot(table_name)

Return a snapshot of table.

get_translator(translator_name)

Get a translator.

Returns a translator specified by translator_name.

get_translators()

Get a list of translators.

Returns a list of translators that describes how to translate from the datasource’s data structures to the Congress tables.

initialize_translators()

override non-applicable parent method as no-op

json_ingester_webhook_handler(table_name, body)

poll()

Periodically called to update new info.

Function called periodically to grab new information, compute deltas, and publish those deltas.

publish(table, data, use_snapshot=False)

register_translator(translator)

Registers translator with congress and validates its schema.

update_from_datasource()

validate_lazy_tables()

override non-applicable parent method as no-op

class congress.datasources.json_ingester.json_ingester.JsonIngesterEndpoints(service)

Bases: congress.dse2.data_service.DataServiceEndPoints

json_ingester_webhook_handler(context, table_name, body)

class congress.datasources.json_ingester.json_ingester.KeyMap

Bases: object

Map associating a unique integer key with each hashable object

add_and_get_key(datum)

Add a datum and return associated key

clear()

Remove all data and keys

remove_and_get_key(datum)

Remove a datum and return associated key