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