ReproducerMessage
- class openmsistream.data_file_io.ReproducerMessage(datafile, *args, **kwargs)
Bases:
Producible
,ABC
Any message that is computed from a data file and produced to a new topic
- Parameters:
datafile (
DownloadDataFileToMemory
) – The DataFile object used to compute this message
- property msg_key
The automatically defined key for these messages is a string version of the path to the original file with “_processing_result” appended
- property callback_kwargs
The callback kwargs defined for these messages are the original datafile name, its relative filepath, and the total number of chunks into which the file was broken.
- get_log_msg(print_every=None)
Prints a message saying that the processing result from [filepath] is being produced, if print_every is defined