quarchpy.fio package

Submodules

quarchpy.fio.FIO_interface module

quarchpy.fio.FIO_interface.convert_qis_stream_to_unix_time(qis_stream_file, unix_stream_start_time)

Converts a QIS stream CSV file to Unix time by adding the unixStreamStartTime to the first column in each row, taking into account the time units provided in both the CSV header and the start time.

Parameters:

  • qis_stream_file (str) – The path to the QIS stream CSV file.

  • unix_stream_start_time (str) – The starting Unix time with units (e.g., “1737374310S”, “1737374310000mS”).

Returns:

Path to the converted CSV file.

Return type:

str

quarchpy.fio.FIO_interface.fio_json_to_csv(output_file)
quarchpy.fio.FIO_interface.follow(thefile, p)
quarchpy.fio.FIO_interface.merge_fio_qis_stream(qis_stream_file, fio_output_file, unix_stream_start_time, output_file=None, rounding_option='round')

Merge FIO and QIS data into a single CSV file.

For each FIO entry:

  • If timestamps match, append FIO data to the corresponding QIS row.

  • If no match, handle based on rounding_option:

    • “round”: Find the nearest QIS time and add FIO data to that row.

    • “insert”: Add a new row with blank QIS data and only FIO data.

Parameters:

  • qis_stream_file (str) – Path to the QIS CSV file (converted to Unix time).

  • fio_output_file (str) – Path to the FIO output file (in JSON format).

  • unix_stream_start_time (str) – Starting Unix timestamp for the QIS stream.

  • output_file (str, optional) – Output file path for the merged CSV. If not provided, the file is saved with “_merged” appended to the QIS file name.

  • rounding_option (str) – Determines how to handle mismatched times (“round” or “insert”).

Returns:

Path to the merged CSV file.

Return type:

str

quarchpy.fio.FIO_interface.return_data(output_file, p, fioCallbacks, myStream, user_data, arguments)
quarchpy.fio.FIO_interface.runFIO(myStream, mode, fioCallbacks, user_data, arguments='', file_name='')
quarchpy.fio.FIO_interface.start_fio(output_file, mode, options, fileName='')

quarchpy.fio.fioDiskFinder module

Module contents

quarchpy.fio.runFIO(myStream, mode, fioCallbacks, user_data, arguments='', file_name='')