arxiv.submission.services.stream.stream module

class arxiv.submission.services.stream.stream.StreamPublisher(partition_key, aws_access_key_id, aws_secret_access_key, region_name, endpoint_url=None, verify=True)[source]

Bases: object

classmethod current_session()[source]

Get/create StreamPublisher for this context.

Return type

StreamPublisher

classmethod get_session(app=None)[source]

Get a new session with the stream.

Return type

StreamPublisher

classmethod init_app(app=None)[source]

Set default configuration params for an application instance.

Return type

None

initialize()[source]

Perform initial checks, e.g. at application start-up.

Return type

None

is_available()[source]

Test our ability to put records.

Return type

bool

put(before, after)[source]

Put an Event on the stream.

Return type

None