@@ -1217,24 +1217,24 @@ def split_measurements(mereni_dir, prohlidky_dir, diesel_dir, verbosity):
12171217 STATIONS_SUBDIR = 'stanice'
12181218
12191219
1220- explain_verbosity (VERBOSITY )
1220+ # explain_verbosity(VERBOSITY)
12211221
1222- print ('——————————————————————————————————PROHLÍDKY VOZIDEL STK A SME:——————————————————————————————————\n ' )
1223- downloaded_inspection_dates = downloaded_dates ([INSPECTIONS_DIR / 'gz' , INSPECTIONS_DIR / 'xml' , INSPECTIONS_DIR / 'parquet' / INSPECTIONS_SUBDIR ])
1224- download_files (SPARQL_ENDPOINT , INSPECTIONS_DIR / 'gz' , PARENT_DATASET_INSPECTIONS , START_DATE , END_DATE , downloaded_inspection_dates , NO_DOWNLOAD_THREADS , MAX_DOWNLOAD_ATTEMPTS , verbosity = VERBOSITY )
1225- extract_files (INSPECTIONS_DIR / 'gz' , INSPECTIONS_DIR / 'xml' , NO_EXTRACT_THREADS , verbosity = VERBOSITY )
1226- parse_inspections_to_parquet (INSPECTIONS_DIR , INSPECTIONS_SUBDIR , DEFECTS_SUBDIR , ACTIONS_SUBDIR , ADR_TYPE_SUBDIR , NO_PARSE_PROCESSES , VERBOSITY , False )
1222+ # print('——————————————————————————————————PROHLÍDKY VOZIDEL STK A SME:——————————————————————————————————\n')
1223+ # downloaded_inspection_dates = downloaded_dates([INSPECTIONS_DIR / 'gz', INSPECTIONS_DIR / 'xml', INSPECTIONS_DIR / 'parquet' / INSPECTIONS_SUBDIR])
1224+ # download_files(SPARQL_ENDPOINT, INSPECTIONS_DIR / 'gz', PARENT_DATASET_INSPECTIONS, START_DATE, END_DATE, downloaded_inspection_dates, NO_DOWNLOAD_THREADS, MAX_DOWNLOAD_ATTEMPTS, verbosity=VERBOSITY)
1225+ # extract_files(INSPECTIONS_DIR / 'gz', INSPECTIONS_DIR / 'xml', NO_EXTRACT_THREADS, verbosity=VERBOSITY)
1226+ # parse_inspections_to_parquet(INSPECTIONS_DIR, INSPECTIONS_SUBDIR, DEFECTS_SUBDIR, ACTIONS_SUBDIR, ADR_TYPE_SUBDIR, NO_PARSE_PROCESSES, VERBOSITY, False)
12271227
12281228 print ('\n ————————————————————————————————DATA Z MĚŘÍCÍCH PŘÍSTROJŮ:————————————————————————————————————\n ' )
12291229 downloaded_measurement_dates = downloaded_dates ([MEASUREMENTS_DIR / 'gz' , MEASUREMENTS_DIR / 'xml' , MEASUREMENTS_DIR / 'parquet' / MEASUREMENTS_ALL_SUBDIR ])
12301230 download_files (SPARQL_ENDPOINT , MEASUREMENTS_DIR / 'gz' , PARENT_DATASET_MEASUREMENTS , START_DATE , END_DATE , downloaded_measurement_dates , NO_DOWNLOAD_THREADS , MAX_DOWNLOAD_ATTEMPTS , verbosity = VERBOSITY )
12311231 extract_files (MEASUREMENTS_DIR / 'gz' , MEASUREMENTS_DIR / 'xml' , NO_EXTRACT_THREADS , verbosity = VERBOSITY )
1232- parse_measurements_to_parquet (MEASUREMENTS_DIR , MEASUREMENTS_ALL_SUBDIR , NO_PARSE_PROCESSES , VERBOSITY , False )
1233- split_measurements (MEASUREMENTS_DIR / 'parquet' / MEASUREMENTS_ALL_SUBDIR , INSPECTIONS_DIR / 'parquet' / INSPECTIONS_SUBDIR , MEASUREMENTS_DIR / 'parquet' / DIESEL_SUBDIR , VERBOSITY )
1232+ # parse_measurements_to_parquet(MEASUREMENTS_DIR, MEASUREMENTS_ALL_SUBDIR, NO_PARSE_PROCESSES, VERBOSITY, False)
1233+ # split_measurements(MEASUREMENTS_DIR / 'parquet' / MEASUREMENTS_ALL_SUBDIR, INSPECTIONS_DIR / 'parquet' / INSPECTIONS_SUBDIR, MEASUREMENTS_DIR / 'parquet' / DIESEL_SUBDIR, VERBOSITY)
12341234
1235- print ('—————————————————————————————————Stanice STK a SME:—————————————————————————————————————————————\n ' )
1236- # Seznam stanic prochází denní aktualizací
1237- clear_folder (STATIONS_DIR , VERBOSITY )
1238- download_stations (SPARQL_ENDPOINT , STATIONS_DIR / 'gz' , DATASET_STATIONS , VERBOSITY )
1239- extract_files (STATIONS_DIR / 'gz' , STATIONS_DIR / 'xml' , 1 , verbosity = VERBOSITY )
1240- parse_stations_to_parquet (STATIONS_DIR , STATIONS_SUBDIR , VERBOSITY , delete = False )
1235+ # print('—————————————————————————————————Stanice STK a SME:—————————————————————————————————————————————\n')
1236+ # # Seznam stanic prochází denní aktualizací
1237+ # clear_folder(STATIONS_DIR, VERBOSITY)
1238+ # download_stations(SPARQL_ENDPOINT, STATIONS_DIR / 'gz', DATASET_STATIONS, VERBOSITY)
1239+ # extract_files(STATIONS_DIR / 'gz', STATIONS_DIR / 'xml', 1, verbosity=VERBOSITY)
1240+ # parse_stations_to_parquet(STATIONS_DIR, STATIONS_SUBDIR, VERBOSITY, delete=False)
0 commit comments