SciXTEMPLATE.API package
Subpackages
- SciXTEMPLATE.API.grpc_modules package
Submodules
SciXTEMPLATE.API.avro_serializer module
- class SciXTEMPLATE.API.avro_serializer.AvroSerialHelper(schema, logger=None)
Bases:
object- avro_deserializer(raw_bytes)
- Parameters:
raw_bytes – The raw bitstream of an incoming AVRO message
- Returns:
The json representation of the AVRO message
- avro_serializer(msg)
- Parameters:
msg – the json representation of the AVRO message
- Returns:
serialized message (bitstream)
SciXTEMPLATE.API.template_client module
The Python AsyncIO implementation of the GRPC template.TemplateInit client.
- class SciXTEMPLATE.API.template_client.Logging(logger)
Bases:
object
- SciXTEMPLATE.API.template_client.input_parser(cli_args)
- SciXTEMPLATE.API.template_client.output_message(args)
- async SciXTEMPLATE.API.template_client.run() None
SciXTEMPLATE.API.template_server module
The Python AsyncIO implementation of the GRPC template server.
- class SciXTEMPLATE.API.template_server.Listener
Bases:
Thread- get_status_redis(job_id, logger)
- subscribe(channel_name='TEMPLATE_statuses')
- class SciXTEMPLATE.API.template_server.Logging(logger)
Bases:
object
- class SciXTEMPLATE.API.template_server.Template(producer, schema, schema_client, logger)
Bases:
TemplateInitServicer- initTemplate(request, context: ServicerContext)
- monitorTemplate(request, context: ServicerContext)
- persistent_connection(job_request, listener)
- session_scope()
Provide a transactional scope for postgres.
- async SciXTEMPLATE.API.template_server.serve() None