data_extraction_transformation/scripts/handpick_specific_csv_files.py (40 lines of code) (raw):

import os import shutil import pandas as pd import argparse def parse_args(): parser = argparse.ArgumentParser(description="Handpick specific timeseries CSV files along with their annotations.json to run them on TCPCBench.") parser.add_argument('-o', '--output-folder', help="Path to the output folder of time series CSV files.") parser.add_argument('-i', '--input-folder', help="Path to the input folder of time series CSV files.") parser.add_argument('-f', '--filtered-signatures-file', help="Path to the CSV file with the signatures to handpick (it has to have a column signature_id).") return parser.parse_args() '''main_dir = "../datasets-original-annotated-2-aggregated-min-json" dest = "../filtered-datasets-original-annotated-2-aggregated-min-json" filtered_signatures_file = "../datasets/more_than_10_alert_summaries_speedometer3_tp6.csv"''' def main(): args = parse_args() main_dir = args.input_folder filtered_signatures_file = args.filtered_signatures_file dest = args.output_folder df = pd.read_csv(filtered_signatures_file) signatures = df['signature_id'].unique().tolist() signatures = list(map(str, signatures)) subfolders = [os.path.join(main_dir, folder) for folder in os.listdir(main_dir) if os.path.isdir(os.path.join(main_dir, folder))] print(subfolders) if not os.path.exists(dest): os.makedirs(dest) counter = 0 for subfolder in subfolders: for root, _, files in os.walk(subfolder): for file in files: if file.endswith(".csv"): csv_file_path = os.path.join(root, file) file_name = os.path.splitext(file)[0] signature = file_name.split("_")[0] if signature in signatures: shutil.copy(csv_file_path, dest) #print("df_list.append(pd.read_csv(\"" + "/content/" + file_name + ".csv" + "\"))") counter += 1 print("Number of copied CSV files:") print(counter) if __name__ == "__main__": main()