KAGRA/Subgroups/CAL/GstLAL/tutorials/step2

Step 2: Dump lock flags from a frame cache file

For the initialization and running the pipeline, please refer step1
Here only the pipeline description part is shown
Access frame cache file by specifying frame_cache and instrument(=K1)

   1 instrument = 'K1'
   2 src = pp.mklalcachesrc(pipeline, location = frame_cache, cache_dsc_regex = instrument)

Define a demultiplexer(demux) to extract data in channel_list

   1 channel_list = []
   2 headkeys     = []
   3 head_dict    = {}
   4 channel_list.append((instrument, 'GRD-LSC_MICH_STATE_N'))
   5 demux = pp.mkframecppchanneldemux(pipeline, src, do_file_checksum = do_file_checksum, skip_bad_files = skip_bad_files, channel_list = map("%s:%s".__mod__, channel_list))

Get channel data into head_dict

   1 headkeys.append("FLG")
   2 for key, chan in zip(headkeys, channel_list):
   3     head_dict[key] = cp.hook_up(pipeline, demux, chan[1],instrument, buf_length)

Define a caps by specifying sampling rate(channel_rate) and resample rate(out_rate)

   1 caps  = "audio/x-raw, format=F64LE, rate=%d" % int(channel_rate)
   2 capsr = "audio/x-raw, format=F64LE, rate=%d" % int(out_rate)
   3 for key in headkeys:
   4     head_dict[key] = cp.caps_and_progress(pipeline, head_dict[key], caps, key)
   5     head_dict[key] = cp.mkresample(pipeline, head_dict[key], 0, False, capsr)

Dump the lock flag into a specified file(output)

   1 pp.mknxydumpsink(pipeline, head_dict["FLG"], output)