Wed, 03 Feb 2021 16:18:14 +0200
Support for module status code in new version.
ioannis@43 | 1 | import sys |
ioannis@43 | 2 | |
victor@7 | 3 | import requests |
victor@7 | 4 | |
ioannis@43 | 5 | try: |
ioannis@43 | 6 | import urllib.parse as urlparse # Python 3 |
ioannis@43 | 7 | except ImportError: |
ioannis@17 | 8 | import urlparse # Python 2 |
ioannis@43 | 9 | |
victor@7 | 10 | import argparse |
madrouin@24 | 11 | import datetime |
madrouin@24 | 12 | import logging |
victor@7 | 13 | import os |
victor@7 | 14 | import re |
ioannis@32 | 15 | from io import BytesIO |
ioannis@45 | 16 | |
victor@7 | 17 | import time |
i@40 | 18 | |
victor@7 | 19 | from zipfile import ZipFile |
madrouin@24 | 20 | |
i@14 | 21 | import yaml |
victor@7 | 22 | |
ioannis@43 | 23 | import netCDF4 as netcdf |
ioannis@43 | 24 | |
ioannis@43 | 25 | requests.packages.urllib3.disable_warnings() |
i@14 | 26 | logger = logging.getLogger(__name__) |
victor@7 | 27 | |
victor@7 | 28 | # The regex to find the measurement id from the measurement page |
victor@7 | 29 | # This should be read from the uploaded file, but would require an extra NetCDF module. |
i@36 | 30 | regex = "<h3>Measurement (?P<measurement_id>.{12,15}) <small>" # {12, 15} to handle both old- and new-style measurement ids. |
victor@7 | 31 | |
victor@7 | 32 | |
victor@7 | 33 | class SCC: |
madrouin@24 | 34 | """A simple class that will attempt to upload a file on the SCC server. |
i@14 | 35 | |
victor@7 | 36 | The uploading is done by simulating a normal browser session. In the current |
madrouin@20 | 37 | version no check is performed, and no feedback is given if the upload |
madrouin@20 | 38 | was successful. If everything is setup correctly, it will work. |
victor@7 | 39 | """ |
victor@7 | 40 | |
i@14 | 41 | def __init__(self, auth, output_dir, base_url): |
moritz@29 | 42 | |
victor@7 | 43 | self.auth = auth |
victor@7 | 44 | self.output_dir = output_dir |
i@14 | 45 | self.base_url = base_url |
victor@7 | 46 | self.session = requests.Session() |
moritz@29 | 47 | self.session.auth = auth |
moritz@29 | 48 | self.session.verify = False |
victor@7 | 49 | |
i@14 | 50 | self.login_url = urlparse.urljoin(self.base_url, 'accounts/login/') |
i@31 | 51 | self.logout_url = urlparse.urljoin(self.base_url, 'accounts/logout/') |
i@31 | 52 | self.list_measurements_url = urlparse.urljoin(self.base_url, 'data_processing/measurements/') |
i@31 | 53 | |
i@14 | 54 | self.upload_url = urlparse.urljoin(self.base_url, 'data_processing/measurements/quick/') |
ioannis@43 | 55 | self.download_hirelpp_pattern = urlparse.urljoin(self.base_url, |
ioannis@34 | 56 | 'data_processing/measurements/{0}/download-hirelpp/') |
ioannis@43 | 57 | self.download_cloudmask_pattern = urlparse.urljoin(self.base_url, |
ioannis@34 | 58 | 'data_processing/measurements/{0}/download-cloudmask/') |
ioannis@34 | 59 | |
ioannis@43 | 60 | self.download_elpp_pattern = urlparse.urljoin(self.base_url, |
moritz@29 | 61 | 'data_processing/measurements/{0}/download-preprocessed/') |
ioannis@43 | 62 | self.download_elda_pattern = urlparse.urljoin(self.base_url, |
moritz@29 | 63 | 'data_processing/measurements/{0}/download-optical/') |
ioannis@45 | 64 | self.download_plots_pattern = urlparse.urljoin(self.base_url, |
moritz@29 | 65 | 'data_processing/measurements/{0}/download-plots/') |
ioannis@43 | 66 | self.download_elic_pattern = urlparse.urljoin(self.base_url, |
ioannis@34 | 67 | 'data_processing/measurements/{0}/download-elic/') |
i@14 | 68 | self.delete_measurement_pattern = urlparse.urljoin(self.base_url, 'admin/database/measurements/{0}/delete/') |
i@31 | 69 | |
i@14 | 70 | self.api_base_url = urlparse.urljoin(self.base_url, 'api/v1/') |
i@31 | 71 | self.api_measurement_pattern = urlparse.urljoin(self.api_base_url, 'measurements/{0}/') |
i@31 | 72 | self.api_measurements_url = urlparse.urljoin(self.api_base_url, 'measurements') |
i@38 | 73 | self.api_sounding_search_pattern = urlparse.urljoin(self.api_base_url, 'sounding_files/?filename={0}') |
i@38 | 74 | self.api_lidarratio_search_pattern = urlparse.urljoin(self.api_base_url, 'lidarratio_files/?filename={0}') |
i@38 | 75 | self.api_overlap_search_pattern = urlparse.urljoin(self.api_base_url, 'overlap_files/?filename={0}') |
ioannis@43 | 76 | |
i@14 | 77 | def login(self, credentials): |
i@31 | 78 | """ Login to SCC. """ |
victor@7 | 79 | logger.debug("Attempting to login to SCC, username %s." % credentials[0]) |
moritz@29 | 80 | login_credentials = {'username': credentials[0], |
moritz@29 | 81 | 'password': credentials[1]} |
victor@7 | 82 | |
i@14 | 83 | logger.debug("Accessing login page at %s." % self.login_url) |
victor@7 | 84 | |
victor@7 | 85 | # Get upload form |
moritz@29 | 86 | login_page = self.session.get(self.login_url) |
i@14 | 87 | |
i@31 | 88 | if not login_page.ok: |
i@31 | 89 | raise self.PageNotAccessibleError('Could not access login pages. Status code %s' % login_page.status_code) |
victor@7 | 90 | |
i@31 | 91 | logger.debug("Submitting credentials.") |
victor@7 | 92 | # Submit the login data |
i@14 | 93 | login_submit = self.session.post(self.login_url, |
moritz@29 | 94 | data=login_credentials, |
victor@7 | 95 | headers={'X-CSRFToken': login_page.cookies['csrftoken'], |
moritz@29 | 96 | 'referer': self.login_url}) |
victor@7 | 97 | return login_submit |
victor@7 | 98 | |
victor@7 | 99 | def logout(self): |
i@31 | 100 | """ Logout from SCC """ |
i@31 | 101 | return self.session.get(self.logout_url, stream=True) |
victor@7 | 102 | |
ioannis@45 | 103 | def upload_file(self, filename, system_id, force_upload, delete_related, rs_filename=None, ov_filename=None, lr_filename=None): |
madrouin@20 | 104 | """ Upload a filename for processing with a specific system. If the |
victor@7 | 105 | upload is successful, it returns the measurement id. """ |
ioannis@43 | 106 | measurement_id = self.measurement_id_from_file(filename) |
ioannis@43 | 107 | |
ioannis@43 | 108 | logger.debug('Checking if a measurement with the same id already exists on the SCC server.') |
ioannis@50 | 109 | existing_measurement, _ = self.get_measurement(measurement_id) |
ioannis@43 | 110 | |
ioannis@43 | 111 | if existing_measurement: |
ioannis@43 | 112 | if force_upload: |
ioannis@43 | 113 | logger.info( |
ioannis@43 | 114 | "Measurement with id {} already exists on the SCC. Trying to delete it...".format(measurement_id)) |
ioannis@43 | 115 | self.delete_measurement(measurement_id, delete_related) |
ioannis@43 | 116 | else: |
ioannis@43 | 117 | logger.error( |
ioannis@43 | 118 | "Measurement with id {} already exists on the SCC. Use --force_upload flag to overwrite it.".format( |
ioannis@43 | 119 | measurement_id)) |
ioannis@43 | 120 | sys.exit(1) |
ioannis@43 | 121 | |
victor@7 | 122 | # Get submit page |
moritz@29 | 123 | upload_page = self.session.get(self.upload_url) |
victor@7 | 124 | |
victor@7 | 125 | # Submit the data |
victor@7 | 126 | upload_data = {'system': system_id} |
victor@7 | 127 | files = {'data': open(filename, 'rb')} |
victor@7 | 128 | |
madrouin@20 | 129 | if rs_filename is not None: |
i@38 | 130 | ancillary_file, _ = self.get_ancillary(rs_filename, 'sounding') |
i@38 | 131 | |
i@38 | 132 | if ancillary_file.already_on_scc: |
i@38 | 133 | logger.warning("Sounding file {0.filename} already on the SCC with id {0.id}. Ignoring it.".format(ancillary_file)) |
i@38 | 134 | else: |
i@38 | 135 | logger.debug('Adding sounding file %s' % rs_filename) |
i@38 | 136 | files['sounding_file'] = open(rs_filename, 'rb') |
madrouin@20 | 137 | |
ioannis@32 | 138 | if ov_filename is not None: |
i@38 | 139 | ancillary_file, _ = self.get_ancillary(ov_filename, 'overlap') |
i@38 | 140 | |
i@38 | 141 | if ancillary_file.already_on_scc: |
i@38 | 142 | logger.warning("Overlap file {0.filename} already on the SCC with id {0.id}. Ignoring it.".format(ancillary_file)) |
i@38 | 143 | else: |
i@38 | 144 | logger.debug('Adding overlap file %s' % ov_filename) |
i@38 | 145 | files['overlap_file'] = open(ov_filename, 'rb') |
i@31 | 146 | |
i@31 | 147 | if lr_filename is not None: |
i@38 | 148 | ancillary_file, _ = self.get_ancillary(lr_filename, 'lidarratio') |
i@38 | 149 | |
i@38 | 150 | if ancillary_file.already_on_scc: |
i@38 | 151 | logger.warning( |
i@38 | 152 | "Lidar ratio file {0.filename} already on the SCC with id {0.id}. Ignoring it.".format(ancillary_file)) |
i@38 | 153 | else: |
i@38 | 154 | logger.debug('Adding lidar ratio file %s' % lr_filename) |
i@38 | 155 | files['lidar_ratio_file'] = open(lr_filename, 'rb') |
i@31 | 156 | |
i@14 | 157 | logger.info("Uploading of file %s started." % filename) |
victor@7 | 158 | |
i@14 | 159 | upload_submit = self.session.post(self.upload_url, |
victor@7 | 160 | data=upload_data, |
victor@7 | 161 | files=files, |
victor@7 | 162 | headers={'X-CSRFToken': upload_page.cookies['csrftoken'], |
moritz@29 | 163 | 'referer': self.upload_url}) |
victor@7 | 164 | |
victor@7 | 165 | if upload_submit.status_code != 200: |
i@14 | 166 | logger.warning("Connection error. Status code: %s" % upload_submit.status_code) |
victor@7 | 167 | return False |
victor@7 | 168 | |
victor@7 | 169 | # Check if there was a redirect to a new page. |
i@14 | 170 | if upload_submit.url == self.upload_url: |
victor@7 | 171 | measurement_id = False |
ioannis@32 | 172 | logger.error("Uploaded file(s) rejected! Try to upload manually to see the error.") |
victor@7 | 173 | else: |
victor@7 | 174 | measurement_id = re.findall(regex, upload_submit.text)[0] |
ioannis@43 | 175 | logger.info("Successfully uploaded measurement with id %s." % measurement_id) |
ioannis@43 | 176 | |
ioannis@43 | 177 | return measurement_id |
ioannis@43 | 178 | |
ioannis@43 | 179 | @staticmethod |
ioannis@43 | 180 | def measurement_id_from_file(filename): |
ioannis@43 | 181 | """ Get the measurement id from the input file. """ |
ioannis@43 | 182 | |
ioannis@43 | 183 | if not os.path.isfile(filename): |
ioannis@43 | 184 | logger.error("File {} does not exist.".format(filename)) |
ioannis@43 | 185 | sys.exit(1) |
ioannis@43 | 186 | |
ioannis@43 | 187 | with netcdf.Dataset(filename) as f: |
ioannis@43 | 188 | try: |
ioannis@43 | 189 | measurement_id = f.Measurement_ID |
ioannis@43 | 190 | except AttributeError: |
ioannis@43 | 191 | logger.error( |
ioannis@43 | 192 | "Input file {} does not contain a Measurement_ID global attribute. Wrong file format?".format( |
ioannis@43 | 193 | filename)) |
ioannis@43 | 194 | sys.exit(1) |
victor@7 | 195 | |
victor@7 | 196 | return measurement_id |
victor@7 | 197 | |
victor@7 | 198 | def download_files(self, measurement_id, subdir, download_url): |
victor@7 | 199 | """ Downloads some files from the download_url to the specified |
madrouin@20 | 200 | subdir. This method is used to download preprocessed file, optical |
victor@7 | 201 | files etc. |
victor@7 | 202 | """ |
ioannis@32 | 203 | # TODO: Make downloading more robust (e.g. in case that files do not exist on server). |
victor@7 | 204 | # Get the file |
moritz@29 | 205 | request = self.session.get(download_url, stream=True) |
moritz@29 | 206 | |
moritz@29 | 207 | if not request.ok: |
moritz@29 | 208 | raise Exception("Could not download files for measurement '%s'" % measurement_id) |
victor@7 | 209 | |
victor@7 | 210 | # Create the dir if it does not exist |
victor@7 | 211 | local_dir = os.path.join(self.output_dir, measurement_id, subdir) |
victor@7 | 212 | if not os.path.exists(local_dir): |
victor@7 | 213 | os.makedirs(local_dir) |
victor@7 | 214 | |
victor@7 | 215 | # Save the file by chunk, needed if the file is big. |
ioannis@43 | 216 | memory_file = BytesIO() |
victor@7 | 217 | |
victor@7 | 218 | for chunk in request.iter_content(chunk_size=1024): |
victor@7 | 219 | if chunk: # filter out keep-alive new chunks |
victor@7 | 220 | memory_file.write(chunk) |
victor@7 | 221 | memory_file.flush() |
victor@7 | 222 | |
victor@7 | 223 | zip_file = ZipFile(memory_file) |
victor@7 | 224 | |
victor@7 | 225 | for ziped_name in zip_file.namelist(): |
victor@7 | 226 | basename = os.path.basename(ziped_name) |
victor@7 | 227 | |
victor@7 | 228 | local_file = os.path.join(local_dir, basename) |
victor@7 | 229 | |
victor@7 | 230 | with open(local_file, 'wb') as f: |
victor@7 | 231 | f.write(zip_file.read(ziped_name)) |
victor@7 | 232 | |
ioannis@43 | 233 | def download_hirelpp(self, measurement_id): |
ioannis@43 | 234 | """ Download hirelpp files for the measurement id. """ |
ioannis@43 | 235 | # Construct the download url |
ioannis@43 | 236 | download_url = self.download_hirelpp_pattern.format(measurement_id) |
ioannis@43 | 237 | try: |
ioannis@50 | 238 | self.download_files(measurement_id, 'hirelpp', download_url) |
ioannis@43 | 239 | except Exception as e: |
ioannis@43 | 240 | logger.error("Could not download HiRElPP files. Error message: {}".format(e)) |
ioannis@43 | 241 | logger.debug('Download exception:', exc_info=True) |
ioannis@43 | 242 | |
ioannis@43 | 243 | def download_cloudmask(self, measurement_id): |
ioannis@43 | 244 | """ Download cloudmask files for the measurement id. """ |
ioannis@43 | 245 | # Construct the download url |
ioannis@43 | 246 | download_url = self.download_cloudmask_pattern.format(measurement_id) |
ioannis@43 | 247 | try: |
ioannis@50 | 248 | self.download_files(measurement_id, 'cloudscreen', download_url) |
ioannis@43 | 249 | except Exception as e: |
ioannis@43 | 250 | logger.error("Could not download cloudscreen files. Error message: {}".format(e)) |
ioannis@43 | 251 | logger.debug('Download exception:', exc_info=True) |
ioannis@43 | 252 | |
ioannis@43 | 253 | def download_elpp(self, measurement_id): |
victor@7 | 254 | """ Download preprocessed files for the measurement id. """ |
victor@7 | 255 | # Construct the download url |
ioannis@43 | 256 | download_url = self.download_elpp_pattern.format(measurement_id) |
ioannis@43 | 257 | try: |
ioannis@50 | 258 | self.download_files(measurement_id, 'elpp', download_url) |
ioannis@43 | 259 | except Exception as e: |
ioannis@43 | 260 | logger.error("Could not download ElPP files. Error message: {}".format(e)) |
ioannis@43 | 261 | logger.debug('Download exception:', exc_info=True) |
victor@7 | 262 | |
ioannis@43 | 263 | def download_elda(self, measurement_id): |
victor@7 | 264 | """ Download optical files for the measurement id. """ |
victor@7 | 265 | # Construct the download url |
ioannis@43 | 266 | download_url = self.download_elda_pattern.format(measurement_id) |
ioannis@43 | 267 | try: |
ioannis@50 | 268 | self.download_files(measurement_id, 'elda', download_url) |
ioannis@43 | 269 | except Exception as e: |
ioannis@43 | 270 | logger.error("Could not download ELDA files. Error message: {}".format(e)) |
ioannis@43 | 271 | logger.debug('Download exception:', exc_info=True) |
victor@7 | 272 | |
ioannis@43 | 273 | def download_plots(self, measurement_id): |
victor@7 | 274 | """ Download profile graphs for the measurement id. """ |
victor@7 | 275 | # Construct the download url |
ioannis@45 | 276 | download_url = self.download_plots_pattern.format(measurement_id) |
ioannis@43 | 277 | try: |
ioannis@50 | 278 | self.download_files(measurement_id, 'elda_plots', download_url) |
ioannis@43 | 279 | except Exception as e: |
ioannis@43 | 280 | logger.error("Could not download ELDA plots. Error message: {}".format(e)) |
ioannis@43 | 281 | logger.debug('Download exception:', exc_info=True) |
victor@7 | 282 | |
ioannis@43 | 283 | def download_elic(self, measurement_id): |
ioannis@43 | 284 | """ Download ELIC files for the measurement id. """ |
ioannis@43 | 285 | # Construct the download url |
ioannis@43 | 286 | download_url = self.download_elic_pattern.format(measurement_id) |
ioannis@43 | 287 | try: |
ioannis@50 | 288 | self.download_files(measurement_id, 'elic', download_url) |
ioannis@43 | 289 | except Exception as e: |
ioannis@43 | 290 | logger.error("Could not download ELIC files. Error message: {}".format(e)) |
ioannis@43 | 291 | logger.debug('Download exception:', exc_info=True) |
ioannis@43 | 292 | |
ioannis@43 | 293 | def download_eldec(self, measurement_id): |
ioannis@43 | 294 | """ Download ELDEC files for the measurement id. """ |
ioannis@43 | 295 | # Construct the download url |
ioannis@43 | 296 | download_url = self.download_elda_pattern.format(measurement_id) # ELDA patter is used for now |
ioannis@43 | 297 | try: |
ioannis@50 | 298 | self.download_files(measurement_id, 'eldec', download_url) |
ioannis@43 | 299 | except Exception as e: |
ioannis@43 | 300 | logger.error("Could not download EDELC files. Error message: {}".format(e)) |
ioannis@43 | 301 | logger.debug('Download exception:', exc_info=True) |
ioannis@43 | 302 | |
ioannis@43 | 303 | def rerun_elpp(self, measurement_id, monitor=True): |
ioannis@45 | 304 | logger.debug("Started rerun_elpp procedure.") |
ioannis@45 | 305 | |
ioannis@45 | 306 | logger.debug("Getting measurement %s" % measurement_id) |
madrouin@26 | 307 | measurement, status = self.get_measurement(measurement_id) |
victor@7 | 308 | |
victor@7 | 309 | if measurement: |
ioannis@45 | 310 | logger.debug("Attempting to rerun ElPP through %s." % measurement.rerun_all_url) |
ioannis@45 | 311 | request = self.session.get(measurement.rerun_elpp_url, stream=True) |
victor@7 | 312 | |
victor@7 | 313 | if request.status_code != 200: |
i@14 | 314 | logger.error( |
i@14 | 315 | "Could not rerun processing for %s. Status code: %s" % (measurement_id, request.status_code)) |
ioannis@45 | 316 | else: |
ioannis@45 | 317 | logger.info("Rerun-elpp command submitted successfully for id {}.".format(measurement_id)) |
victor@7 | 318 | |
victor@7 | 319 | if monitor: |
victor@7 | 320 | self.monitor_processing(measurement_id) |
victor@7 | 321 | |
victor@7 | 322 | def rerun_all(self, measurement_id, monitor=True): |
victor@7 | 323 | logger.debug("Started rerun_all procedure.") |
victor@7 | 324 | |
victor@7 | 325 | logger.debug("Getting measurement %s" % measurement_id) |
madrouin@26 | 326 | measurement, status = self.get_measurement(measurement_id) |
victor@7 | 327 | |
victor@7 | 328 | if measurement: |
victor@7 | 329 | logger.debug("Attempting to rerun all processing through %s." % measurement.rerun_all_url) |
victor@7 | 330 | |
moritz@29 | 331 | request = self.session.get(measurement.rerun_all_url, stream=True) |
victor@7 | 332 | |
victor@7 | 333 | if request.status_code != 200: |
victor@7 | 334 | logger.error("Could not rerun pre processing for %s. Status code: %s" % |
victor@7 | 335 | (measurement_id, request.status_code)) |
ioannis@45 | 336 | else: |
ioannis@45 | 337 | logger.info("Rerun-all command submitted successfully for id {}.".format(measurement_id)) |
victor@7 | 338 | |
victor@7 | 339 | if monitor: |
victor@7 | 340 | self.monitor_processing(measurement_id) |
victor@7 | 341 | |
ioannis@45 | 342 | def process(self, filename, system_id, monitor, force_upload, delete_related, rs_filename=None, lr_filename=None, ov_filename=None): |
victor@7 | 343 | """ Upload a file for processing and wait for the processing to finish. |
victor@7 | 344 | If the processing is successful, it will download all produced files. |
victor@7 | 345 | """ |
victor@7 | 346 | logger.info("--- Processing started on %s. ---" % datetime.datetime.now()) |
victor@7 | 347 | # Upload file |
ioannis@50 | 348 | logger.info("Uploading file.") |
ioannis@45 | 349 | measurement_id = self.upload_file(filename, system_id, force_upload, delete_related, |
ioannis@32 | 350 | rs_filename=rs_filename, |
ioannis@32 | 351 | lr_filename=lr_filename, |
ioannis@32 | 352 | ov_filename=ov_filename) |
ioannis@43 | 353 | |
ioannis@32 | 354 | if measurement_id and monitor: |
ioannis@50 | 355 | logger.info("Monitoring processing") |
moritz@29 | 356 | return self.monitor_processing(measurement_id) |
victor@7 | 357 | |
moritz@29 | 358 | return None |
victor@7 | 359 | |
victor@7 | 360 | def monitor_processing(self, measurement_id): |
victor@7 | 361 | """ Monitor the processing progress of a measurement id""" |
victor@7 | 362 | |
madrouin@24 | 363 | # try to deal with error 404 |
madrouin@24 | 364 | error_count = 0 |
ioannis@53 | 365 | error_max = 3 |
ioannis@53 | 366 | time_sleep = 3 |
madrouin@24 | 367 | |
madrouin@25 | 368 | # try to wait for measurement to appear in API |
madrouin@24 | 369 | measurement = None |
ioannis@50 | 370 | logger.info("Looking for measurement %s on the SCC.", measurement_id) |
madrouin@26 | 371 | while error_count < error_max: |
madrouin@26 | 372 | time.sleep(time_sleep) |
madrouin@26 | 373 | measurement, status = self.get_measurement(measurement_id) |
madrouin@26 | 374 | if status != 200 and error_count < error_max: |
ioannis@32 | 375 | logger.error("Measurement not found. waiting %ds", time_sleep) |
madrouin@24 | 376 | error_count += 1 |
madrouin@26 | 377 | else: |
madrouin@26 | 378 | break |
madrouin@24 | 379 | |
madrouin@24 | 380 | if error_count == error_max: |
ioannis@32 | 381 | logger.critical("Measurement %s doesn't seem to exist", measurement_id) |
madrouin@26 | 382 | sys.exit(1) |
madrouin@26 | 383 | |
ioannis@45 | 384 | logger.info('Measurement %s found.', measurement_id) |
madrouin@24 | 385 | |
victor@7 | 386 | if measurement is not None: |
victor@7 | 387 | while measurement.is_running: |
ioannis@53 | 388 | measurement.log_processing_status() |
victor@7 | 389 | time.sleep(10) |
madrouin@26 | 390 | measurement, status = self.get_measurement(measurement_id) |
madrouin@24 | 391 | |
ioannis@34 | 392 | logger.info("Measurement processing finished.") |
ioannis@53 | 393 | measurement.log_detailed_status() |
ioannis@53 | 394 | |
ioannis@43 | 395 | if measurement.hirelpp == 127: |
ioannis@43 | 396 | logger.info("Downloading HiRElPP files.") |
ioannis@43 | 397 | self.download_hirelpp(measurement_id) |
ioannis@43 | 398 | if measurement.cloudmask == 127: |
ioannis@43 | 399 | logger.info("Downloading cloud screening files.") |
ioannis@43 | 400 | self.download_cloudmask(measurement_id) |
ioannis@43 | 401 | if measurement.elpp == 127: |
ioannis@45 | 402 | logger.info("Downloading ElPP files.") |
ioannis@43 | 403 | self.download_elpp(measurement_id) |
ioannis@43 | 404 | if measurement.elda == 127: |
ioannis@43 | 405 | logger.info("Downloading ELDA files.") |
ioannis@43 | 406 | self.download_elda(measurement_id) |
ioannis@50 | 407 | logger.info("Downloading ELDA plots.") |
ioannis@43 | 408 | self.download_plots(measurement_id) |
ioannis@43 | 409 | if measurement.elic == 127: |
ioannis@43 | 410 | logger.info("Downloading ELIC files.") |
ioannis@43 | 411 | self.download_elic(measurement_id) |
ioannis@53 | 412 | if measurement.is_calibration and measurement.eldec==0: |
ioannis@43 | 413 | logger.info("Downloading ELDEC files.") |
ioannis@43 | 414 | self.download_eldec(measurement_id) |
victor@7 | 415 | logger.info("--- Processing finished. ---") |
ioannis@43 | 416 | |
victor@7 | 417 | return measurement |
victor@7 | 418 | |
ioannis@43 | 419 | def get_measurement(self, measurement_id): |
victor@7 | 420 | |
ioannis@45 | 421 | if measurement_id is None: # Is this still required? |
victor@7 | 422 | return None |
victor@7 | 423 | |
i@31 | 424 | measurement_url = self.api_measurement_pattern.format(measurement_id) |
i@31 | 425 | logger.debug("Measurement API URL: %s" % measurement_url) |
victor@7 | 426 | |
moritz@29 | 427 | response = self.session.get(measurement_url) |
victor@7 | 428 | |
ioannis@43 | 429 | response_dict = None |
ioannis@45 | 430 | |
ioannis@43 | 431 | if response.status_code == 200: |
ioannis@43 | 432 | response_dict = response.json() |
ioannis@45 | 433 | elif response.status_code == 404: |
ioannis@43 | 434 | logger.info("No measurement with id %s found on the SCC." % measurement_id) |
ioannis@45 | 435 | else: |
i@14 | 436 | logger.error('Could not access API. Status code %s.' % response.status_code) |
victor@7 | 437 | |
victor@7 | 438 | if response_dict: |
ioannis@43 | 439 | measurement = Measurement(self.base_url, response_dict) |
victor@7 | 440 | else: |
ioannis@45 | 441 | measurement = None |
victor@7 | 442 | |
ioannis@45 | 443 | return measurement, response.status_code |
victor@7 | 444 | |
ioannis@45 | 445 | def delete_measurement(self, measurement_id, delete_related): |
victor@7 | 446 | """ Deletes a measurement with the provided measurement id. The user |
madrouin@20 | 447 | should have the appropriate permissions. |
madrouin@20 | 448 | |
victor@7 | 449 | The procedures is performed directly through the web interface and |
victor@7 | 450 | NOT through the API. |
victor@7 | 451 | """ |
victor@7 | 452 | # Get the measurement object |
i@31 | 453 | measurement, _ = self.get_measurement(measurement_id) |
victor@7 | 454 | |
victor@7 | 455 | # Check that it exists |
victor@7 | 456 | if measurement is None: |
victor@7 | 457 | logger.warning("Nothing to delete.") |
victor@7 | 458 | return None |
victor@7 | 459 | |
victor@7 | 460 | # Go the the page confirming the deletion |
moritz@29 | 461 | delete_url = self.delete_measurement_pattern.format(measurement_id) |
ioannis@43 | 462 | |
moritz@29 | 463 | confirm_page = self.session.get(delete_url) |
victor@7 | 464 | |
victor@7 | 465 | # Check that the page opened properly |
victor@7 | 466 | if confirm_page.status_code != 200: |
victor@7 | 467 | logger.warning("Could not open delete page. Status: {0}".format(confirm_page.status_code)) |
victor@7 | 468 | return None |
victor@7 | 469 | |
ioannis@43 | 470 | # Get the delete related value |
ioannis@43 | 471 | if delete_related: |
ioannis@43 | 472 | delete_related_option = 'delete_related' |
ioannis@43 | 473 | else: |
ioannis@43 | 474 | delete_related_option = 'not_delete_related' |
ioannis@43 | 475 | |
victor@7 | 476 | # Delete the measurement |
victor@7 | 477 | delete_page = self.session.post(delete_url, |
ioannis@43 | 478 | data={'post': 'yes', |
ioannis@43 | 479 | 'select_delete_related_measurements': delete_related_option}, |
victor@7 | 480 | headers={'X-CSRFToken': confirm_page.cookies['csrftoken'], |
victor@7 | 481 | 'referer': delete_url} |
victor@7 | 482 | ) |
i@31 | 483 | if not delete_page.ok: |
victor@7 | 484 | logger.warning("Something went wrong. Delete page status: {0}".format( |
victor@7 | 485 | delete_page.status_code)) |
victor@7 | 486 | return None |
victor@7 | 487 | |
victor@7 | 488 | logger.info("Deleted measurement {0}".format(measurement_id)) |
victor@7 | 489 | return True |
victor@7 | 490 | |
victor@7 | 491 | def available_measurements(self): |
victor@7 | 492 | """ Get a list of available measurement on the SCC. """ |
i@31 | 493 | response = self.session.get(self.api_measurements_url) |
victor@7 | 494 | response_dict = response.json() |
victor@7 | 495 | |
victor@7 | 496 | if response_dict: |
victor@7 | 497 | measurement_list = response_dict['objects'] |
i@14 | 498 | measurements = [Measurement(self.base_url, measurement_dict) for measurement_dict in measurement_list] |
victor@7 | 499 | logger.info("Found %s measurements on the SCC." % len(measurements)) |
victor@7 | 500 | else: |
victor@7 | 501 | logger.warning("No response received from the SCC when asked for available measurements.") |
ioannis@43 | 502 | measurements = None |
victor@7 | 503 | |
victor@7 | 504 | return measurements |
victor@7 | 505 | |
moritz@29 | 506 | def list_measurements(self, station=None, system=None, start=None, stop=None, upload_status=None, |
moritz@29 | 507 | processing_status=None, optical_processing=None): |
moritz@29 | 508 | |
i@31 | 509 | # TODO: Change this to work through the API |
i@31 | 510 | |
moritz@29 | 511 | # Need to set to empty string if not specified, we won't get any results |
moritz@29 | 512 | params = { |
moritz@29 | 513 | "station": station if station is not None else "", |
moritz@29 | 514 | "system": system if system is not None else "", |
moritz@29 | 515 | "stop": stop if stop is not None else "", |
moritz@29 | 516 | "start": start if start is not None else "", |
moritz@29 | 517 | "upload_status": upload_status if upload_status is not None else "", |
moritz@29 | 518 | "preprocessing_status": processing_status if processing_status is not None else "", |
moritz@29 | 519 | "optical_processing_status": optical_processing if optical_processing is not None else "" |
moritz@29 | 520 | } |
i@31 | 521 | |
i@31 | 522 | response_txt = self.session.get(self.list_measurements_url, params=params).text |
moritz@29 | 523 | tbl_rgx = re.compile(r'<table id="measurements">(.*?)</table>', re.DOTALL) |
moritz@29 | 524 | entry_rgx = re.compile(r'<tr>(.*?)</tr>', re.DOTALL) |
moritz@29 | 525 | measurement_rgx = re.compile( |
moritz@29 | 526 | r'.*?<td><a[^>]*>(\w+)</a>.*?<td>.*?<td>([\w-]+ [\w:]+)</td>.*<td data-order="([-]?\d+),([-]?\d+),([-]?\d+)".*', |
moritz@29 | 527 | re.DOTALL) |
i@31 | 528 | matches = tbl_rgx.findall(response_txt) |
moritz@29 | 529 | if len(matches) != 1: |
moritz@29 | 530 | return [] |
moritz@29 | 531 | |
moritz@29 | 532 | ret = [] |
moritz@29 | 533 | for entry in entry_rgx.finditer(matches[0]): |
moritz@29 | 534 | m = measurement_rgx.match(entry.string[entry.start(0):entry.end(0)]) |
moritz@29 | 535 | if m: |
moritz@29 | 536 | name, date, upload, preproc, optical = m.groups() |
moritz@29 | 537 | ret.append( |
moritz@29 | 538 | Measurement(self.base_url, {"id": name, "upload": int(upload), "pre_processing": int(preproc), |
moritz@29 | 539 | "processing": int(optical)})) |
moritz@29 | 540 | |
moritz@29 | 541 | return ret |
moritz@29 | 542 | |
ioannis@43 | 543 | def measurement_id_for_date(self, t1, call_sign, base_number=0): |
victor@7 | 544 | """ Give the first available measurement id on the SCC for the specific |
madrouin@20 | 545 | date. |
victor@7 | 546 | """ |
victor@7 | 547 | date_str = t1.strftime('%Y%m%d') |
i@31 | 548 | base_id = "%s%s" % (date_str, call_sign) |
i@31 | 549 | search_url = urlparse.urljoin(self.api_base_url, 'measurements/?id__startswith=%s' % base_id) |
victor@7 | 550 | |
moritz@29 | 551 | response = self.session.get(search_url) |
victor@7 | 552 | |
victor@7 | 553 | response_dict = response.json() |
victor@7 | 554 | |
victor@7 | 555 | measurement_id = None |
victor@7 | 556 | |
victor@7 | 557 | if response_dict: |
victor@7 | 558 | measurement_list = response_dict['objects'] |
i@31 | 559 | |
i@31 | 560 | if len(measurement_list) == 100: |
i@31 | 561 | raise ValueError('No available measurement id found.') |
i@31 | 562 | |
victor@7 | 563 | existing_ids = [measurement_dict['id'] for measurement_dict in measurement_list] |
victor@7 | 564 | |
victor@7 | 565 | measurement_number = base_number |
i@31 | 566 | measurement_id = "%s%02i" % (base_id, measurement_number) |
victor@7 | 567 | |
victor@7 | 568 | while measurement_id in existing_ids: |
victor@7 | 569 | measurement_number = measurement_number + 1 |
i@31 | 570 | measurement_id = "%s%02i" % (base_id, measurement_number) |
victor@7 | 571 | |
victor@7 | 572 | return measurement_id |
victor@7 | 573 | |
i@40 | 574 | def get_ancillary(self, file_path, file_type): |
i@38 | 575 | """ |
i@38 | 576 | Try to get the ancillary file data from the SCC API. |
i@38 | 577 | |
i@38 | 578 | The result will always be an API object. If the file does not exist, the .exists property is set to False. |
i@38 | 579 | |
i@38 | 580 | Parameters |
i@38 | 581 | ---------- |
i@40 | 582 | file_path : str |
i@40 | 583 | Path of the uploaded file. |
i@38 | 584 | file_type : str |
i@38 | 585 | Type of ancillary file. One of 'sounding', 'overlap', 'lidarratio'. |
i@38 | 586 | |
i@38 | 587 | Returns |
i@38 | 588 | : AncillaryFile |
i@38 | 589 | The api object. |
i@38 | 590 | """ |
i@38 | 591 | assert file_type in ['sounding', 'overlap', 'lidarratio'] |
i@38 | 592 | |
i@40 | 593 | filename = os.path.basename(file_path) |
i@40 | 594 | |
i@38 | 595 | if file_type == 'sounding': |
i@38 | 596 | file_url = self.api_sounding_search_pattern.format(filename) |
i@38 | 597 | elif file_type == 'overlap': |
i@38 | 598 | file_url = self.api_overlap_search_pattern.format(filename) |
i@38 | 599 | else: |
i@38 | 600 | file_url = self.api_lidarratio_search_pattern.format(filename) |
i@38 | 601 | |
i@38 | 602 | response = self.session.get(file_url) |
i@38 | 603 | |
i@38 | 604 | if not response.ok: |
i@38 | 605 | logger.error('Could not access API. Status code %s.' % response.status_code) |
i@38 | 606 | return None, response.status_code |
i@38 | 607 | |
i@38 | 608 | response_dict = response.json() |
i@38 | 609 | object_list = response_dict['objects'] |
i@38 | 610 | |
i@38 | 611 | logger.debug("Ancillary file JSON: {0}".format(object_list)) |
i@38 | 612 | |
i@38 | 613 | if object_list: |
i@38 | 614 | ancillary_file = AncillaryFile(self.api_base_url, object_list[0]) # Assume only one file is returned |
i@38 | 615 | else: |
i@38 | 616 | ancillary_file = AncillaryFile(self.api_base_url, None) # Create an empty object |
i@38 | 617 | |
i@38 | 618 | return ancillary_file, response.status_code |
i@38 | 619 | |
ioannis@43 | 620 | def __enter__(self): |
ioannis@43 | 621 | return self |
victor@7 | 622 | |
ioannis@43 | 623 | def __exit__(self, *args): |
ioannis@43 | 624 | logger.debug("Closing SCC connection session.") |
ioannis@43 | 625 | self.session.close() |
ioannis@43 | 626 | |
i@31 | 627 | class PageNotAccessibleError(RuntimeError): |
i@31 | 628 | pass |
ioannis@43 | 629 | |
victor@7 | 630 | |
ioannis@17 | 631 | class ApiObject(object): |
victor@7 | 632 | """ A generic class object. """ |
victor@7 | 633 | |
i@14 | 634 | def __init__(self, base_url, dict_response): |
i@14 | 635 | self.base_url = base_url |
victor@7 | 636 | |
victor@7 | 637 | if dict_response: |
victor@7 | 638 | # Add the dictionary key value pairs as object properties |
victor@7 | 639 | for key, value in dict_response.items(): |
ioannis@17 | 640 | # logger.debug('Setting key {0} to value {1}'.format(key, value)) |
ioannis@17 | 641 | try: |
ioannis@17 | 642 | setattr(self, key, value) |
ioannis@17 | 643 | except: |
ioannis@17 | 644 | logger.warning('Could not set attribute {0} to value {1}'.format(key, value)) |
victor@7 | 645 | self.exists = True |
victor@7 | 646 | else: |
victor@7 | 647 | self.exists = False |
victor@7 | 648 | |
victor@7 | 649 | |
victor@7 | 650 | class Measurement(ApiObject): |
ioannis@43 | 651 | """ This class represents the measurement object as returned in the SCC API. |
ioannis@43 | 652 | """ |
victor@7 | 653 | |
i@14 | 654 | def __init__(self, base_url, dict_response): |
victor@7 | 655 | |
ioannis@45 | 656 | # Define expected attributes to assist debugging |
ioannis@53 | 657 | |
ioannis@53 | 658 | self.hirelpp = None |
ioannis@53 | 659 | self.hirelpp_exit_code = None |
ioannis@43 | 660 | self.cloudmask = None |
ioannis@53 | 661 | self.cloudmask_exit_code = None |
ioannis@53 | 662 | self.elpp = None |
ioannis@53 | 663 | self.elpp_exit_code = None |
ioannis@43 | 664 | self.elda = None |
ioannis@53 | 665 | self.elda_exit_code = None |
ioannis@43 | 666 | self.elic = None |
ioannis@53 | 667 | self.elic_exit_code = None |
ioannis@53 | 668 | self.eldec = None |
ioannis@53 | 669 | self.eldec_exit_code = None |
ioannis@53 | 670 | self.elquick = None |
ioannis@53 | 671 | self.elquick_exit_code = None |
ioannis@53 | 672 | |
ioannis@43 | 673 | self.id = None |
ioannis@43 | 674 | self.is_calibration = None |
ioannis@43 | 675 | self.is_running = None |
ioannis@53 | 676 | |
ioannis@43 | 677 | self.resource_uri = None |
ioannis@43 | 678 | self.start = None |
ioannis@43 | 679 | self.stop = None |
ioannis@43 | 680 | self.system = None |
ioannis@43 | 681 | self.upload = None |
ioannis@43 | 682 | |
ioannis@45 | 683 | super().__init__(base_url, dict_response) |
victor@7 | 684 | |
ioannis@53 | 685 | def log_processing_status(self): |
ioannis@53 | 686 | """ Log module status. """ |
ioannis@53 | 687 | logger.info("Measurement is being processed. Status: {}, {}, {}, {}, {}, {}). Please wait.".format( |
ioannis@53 | 688 | self.upload, |
ioannis@53 | 689 | self.hirelpp, |
ioannis@53 | 690 | self.cloudmask, |
ioannis@53 | 691 | self.elpp, |
ioannis@53 | 692 | self.elda, |
ioannis@53 | 693 | self.elic)) |
ioannis@53 | 694 | |
ioannis@53 | 695 | def log_detailed_status(self): |
ioannis@53 | 696 | """ Log module exit and status codes.""" |
ioannis@53 | 697 | logger.info("Measurement exit status:".format(self.id)) |
ioannis@53 | 698 | if self.is_calibration: |
ioannis@53 | 699 | self._log_module_status('ElPP', self.elpp, self.elpp_exit_code) |
ioannis@53 | 700 | self._log_module_status('ElDEC', self.eldec, self.eldec_exit_code) |
ioannis@53 | 701 | else: |
ioannis@53 | 702 | self._log_module_status('HiRElPP', self.hirelpp, self.hirelpp_exit_code) |
ioannis@53 | 703 | self._log_module_status('CloudScreen', self.cloudmask, self.cloudmask_exit_code) |
ioannis@53 | 704 | self._log_module_status('ElPP', self.elpp, self.elpp_exit_code) |
ioannis@53 | 705 | self._log_module_status('ELDA', self.elda, self.elda_exit_code) |
ioannis@53 | 706 | self._log_module_status('ELIC', self.elic, self.elic_exit_code) |
ioannis@53 | 707 | self._log_module_status('ELQuick', self.elquick, self.elquick_exit_code) |
ioannis@53 | 708 | |
ioannis@53 | 709 | def _log_module_status(self, name, status, exit_code): |
ioannis@53 | 710 | if exit_code: |
ioannis@53 | 711 | logger.warning("{0} exit code: {2[exit_code]} - {2[description]}".format(name, status, exit_code)) |
ioannis@53 | 712 | else: |
ioannis@53 | 713 | logger.info("{0} exit code: {2}".format(name, status, exit_code)) |
ioannis@53 | 714 | |
ioannis@43 | 715 | @property |
ioannis@43 | 716 | def rerun_elda_url(self): |
ioannis@43 | 717 | url_pattern = urlparse.urljoin(self.base_url, 'data_processing/measurements/{0}/rerun-elda/') |
ioannis@43 | 718 | return url_pattern.format(self.id) |
victor@7 | 719 | |
victor@7 | 720 | @property |
ioannis@43 | 721 | def rerun_elpp_url(self): |
ioannis@43 | 722 | url_pattern = urlparse.urljoin(self.base_url, 'data_processing/measurements/{0}/rerun-elpp/') |
i@14 | 723 | return url_pattern.format(self.id) |
victor@7 | 724 | |
victor@7 | 725 | @property |
victor@7 | 726 | def rerun_all_url(self): |
i@14 | 727 | ulr_pattern = urlparse.urljoin(self.base_url, 'data_processing/measurements/{0}/rerun-all/') |
i@14 | 728 | return ulr_pattern.format(self.id) |
victor@7 | 729 | |
victor@7 | 730 | def __str__(self): |
ioannis@43 | 731 | return "Measurement {}".format(self.id) |
victor@7 | 732 | |
victor@7 | 733 | |
i@38 | 734 | class AncillaryFile(ApiObject): |
i@38 | 735 | """ This class represents the ancilalry file object as returned in the SCC API. |
i@38 | 736 | """ |
i@38 | 737 | @property |
i@38 | 738 | def already_on_scc(self): |
i@38 | 739 | if self.exists is False: |
i@38 | 740 | return False |
i@38 | 741 | |
i@38 | 742 | return not self.status == 'missing' |
i@38 | 743 | |
i@38 | 744 | def __str__(self): |
i@38 | 745 | return "%s: %s, %s" % (self.id, |
i@38 | 746 | self.filename, |
i@38 | 747 | self.status) |
i@38 | 748 | |
i@38 | 749 | |
ioannis@45 | 750 | def process_file(filename, system_id, settings, force_upload, delete_related, |
ioannis@45 | 751 | monitor=True, rs_filename=None, lr_filename=None, ov_filename=None): |
ioannis@32 | 752 | """ Shortcut function to process a file to the SCC. """ |
ioannis@32 | 753 | logger.info("Processing file %s, using system %s" % (filename, system_id)) |
victor@7 | 754 | |
ioannis@43 | 755 | with SCC(settings['basic_credentials'], settings['output_dir'], settings['base_url']) as scc: |
ioannis@43 | 756 | scc.login(settings['website_credentials']) |
ioannis@45 | 757 | measurement = scc.process(filename, system_id, |
ioannis@45 | 758 | force_upload=force_upload, |
ioannis@45 | 759 | delete_related=delete_related, |
ioannis@45 | 760 | monitor=monitor, |
ioannis@45 | 761 | rs_filename=rs_filename, |
ioannis@45 | 762 | lr_filename=lr_filename, |
ioannis@45 | 763 | ov_filename=ov_filename) |
ioannis@43 | 764 | scc.logout() |
victor@7 | 765 | return measurement |
victor@7 | 766 | |
victor@7 | 767 | |
ioannis@45 | 768 | def delete_measurements(measurement_ids, delete_related, settings): |
moritz@29 | 769 | """ Shortcut function to delete measurements from the SCC. """ |
ioannis@45 | 770 | with SCC(settings['basic_credentials'], settings['output_dir'], settings['base_url']) as scc: |
ioannis@45 | 771 | scc.login(settings['website_credentials']) |
ioannis@45 | 772 | for m_id in measurement_ids: |
ioannis@45 | 773 | logger.info("Deleting %s" % m_id) |
ioannis@45 | 774 | scc.delete_measurement(m_id, delete_related) |
ioannis@45 | 775 | scc.logout() |
moritz@29 | 776 | |
moritz@29 | 777 | |
moritz@29 | 778 | def rerun_all(measurement_ids, monitor, settings): |
moritz@29 | 779 | """ Shortcut function to rerun measurements from the SCC. """ |
i@14 | 780 | |
ioannis@43 | 781 | with SCC(settings['basic_credentials'], settings['output_dir'], settings['base_url']) as scc: |
ioannis@43 | 782 | scc.login(settings['website_credentials']) |
ioannis@45 | 783 | for m_id in measurement_ids: |
ioannis@45 | 784 | logger.info("Rerunning all products for %s" % m_id) |
ioannis@45 | 785 | scc.rerun_all(m_id, monitor) |
ioannis@43 | 786 | scc.logout() |
victor@7 | 787 | |
victor@7 | 788 | |
moritz@29 | 789 | def rerun_processing(measurement_ids, monitor, settings): |
victor@7 | 790 | """ Shortcut function to delete a measurement from the SCC. """ |
i@14 | 791 | |
ioannis@43 | 792 | with SCC(settings['basic_credentials'], settings['output_dir'], settings['base_url']) as scc: |
ioannis@43 | 793 | scc.login(settings['website_credentials']) |
ioannis@45 | 794 | for m_id in measurement_ids: |
ioannis@45 | 795 | logger.info("Rerunning (optical) processing for %s" % m_id) |
ioannis@45 | 796 | scc.rerun_elpp(m_id, monitor) |
ioannis@45 | 797 | scc.logout() |
moritz@29 | 798 | |
moritz@29 | 799 | |
moritz@29 | 800 | def list_measurements(settings, station=None, system=None, start=None, stop=None, upload_status=None, |
moritz@29 | 801 | preprocessing_status=None, |
moritz@29 | 802 | optical_processing=None): |
moritz@29 | 803 | """List all available measurements""" |
ioannis@45 | 804 | with SCC(settings['basic_credentials'], settings['output_dir'], settings['base_url']) as scc: |
ioannis@45 | 805 | scc.login(settings['website_credentials']) |
ioannis@45 | 806 | ret = scc.list_measurements(station=station, system=system, start=start, stop=stop, upload_status=upload_status, |
ioannis@45 | 807 | processing_status=preprocessing_status, optical_processing=optical_processing) |
ioannis@45 | 808 | for entry in ret: |
ioannis@45 | 809 | print("%s" % entry.id) |
ioannis@43 | 810 | scc.logout() |
victor@7 | 811 | |
victor@7 | 812 | |
moritz@29 | 813 | def download_measurements(measurement_ids, download_preproc, download_optical, download_graph, settings): |
moritz@29 | 814 | """Download all measurements for the specified IDs""" |
ioannis@43 | 815 | with SCC(settings['basic_credentials'], settings['output_dir'], settings['base_url']) as scc: |
ioannis@43 | 816 | scc.login(settings['website_credentials']) |
ioannis@45 | 817 | for m_id in measurement_ids: |
ioannis@45 | 818 | if download_preproc: |
ioannis@45 | 819 | logger.info("Downloading preprocessed files for '%s'" % m_id) |
ioannis@45 | 820 | scc.download_elpp(m_id) |
ioannis@45 | 821 | logger.info("Complete") |
ioannis@45 | 822 | if download_optical: |
ioannis@45 | 823 | logger.info("Downloading optical files for '%s'" % m_id) |
ioannis@45 | 824 | scc.download_elda(m_id) |
ioannis@45 | 825 | logger.info("Complete") |
ioannis@45 | 826 | if download_graph: |
ioannis@45 | 827 | logger.info("Downloading profile graph files for '%s'" % m_id) |
ioannis@45 | 828 | scc.download_plots(m_id) |
ioannis@45 | 829 | logger.info("Complete") |
ioannis@43 | 830 | scc.logout() |
i@14 | 831 | |
i@14 | 832 | |
moritz@29 | 833 | def settings_from_path(config_file_path): |
i@14 | 834 | """ Read the configuration file. |
i@14 | 835 | |
i@14 | 836 | The file should be in YAML syntax.""" |
i@14 | 837 | |
i@14 | 838 | if not os.path.isfile(config_file_path): |
moritz@29 | 839 | raise argparse.ArgumentTypeError("Wrong path for configuration file (%s)" % config_file_path) |
i@14 | 840 | |
i@14 | 841 | with open(config_file_path) as yaml_file: |
i@14 | 842 | try: |
i@14 | 843 | settings = yaml.safe_load(yaml_file) |
i@14 | 844 | logger.debug("Read settings file(%s)" % config_file_path) |
moritz@29 | 845 | except Exception: |
moritz@29 | 846 | raise argparse.ArgumentTypeError("Could not parse YAML file (%s)" % config_file_path) |
i@14 | 847 | |
i@14 | 848 | # YAML limitation: does not read tuples |
i@14 | 849 | settings['basic_credentials'] = tuple(settings['basic_credentials']) |
i@14 | 850 | settings['website_credentials'] = tuple(settings['website_credentials']) |
i@14 | 851 | return settings |
i@14 | 852 | |
i@14 | 853 | |
moritz@29 | 854 | # Setup for command specific parsers |
moritz@29 | 855 | def setup_delete(parser): |
moritz@29 | 856 | def delete_from_args(parsed): |
ioannis@45 | 857 | delete_measurements(parsed.IDs, |
ioannis@45 | 858 | delete_related=False, |
ioannis@45 | 859 | settings=parsed.config) |
moritz@29 | 860 | |
moritz@29 | 861 | parser.add_argument("IDs", nargs="+", help="measurement IDs to delete.") |
moritz@29 | 862 | parser.set_defaults(execute=delete_from_args) |
moritz@29 | 863 | |
moritz@29 | 864 | |
moritz@29 | 865 | def setup_rerun_all(parser): |
moritz@29 | 866 | def rerun_all_from_args(parsed): |
moritz@29 | 867 | rerun_all(parsed.IDs, parsed.process, parsed.config) |
moritz@29 | 868 | |
moritz@29 | 869 | parser.add_argument("IDs", nargs="+", help="Measurement IDs to rerun.") |
moritz@29 | 870 | parser.add_argument("-p", "--process", help="Wait for the results of the processing.", |
moritz@29 | 871 | action="store_true") |
moritz@29 | 872 | parser.set_defaults(execute=rerun_all_from_args) |
moritz@29 | 873 | |
moritz@29 | 874 | |
ioannis@45 | 875 | def setup_rerun_elpp(parser): |
moritz@29 | 876 | def rerun_processing_from_args(parsed): |
moritz@29 | 877 | rerun_processing(parsed.IDs, parsed.process, parsed.config) |
moritz@29 | 878 | |
moritz@29 | 879 | parser.add_argument("IDs", nargs="+", help="Measurement IDs to rerun the processing on.") |
moritz@29 | 880 | parser.add_argument("-p", "--process", help="Wait for the results of the processing.", |
moritz@29 | 881 | action="store_true") |
moritz@29 | 882 | parser.set_defaults(execute=rerun_processing_from_args) |
moritz@29 | 883 | |
moritz@29 | 884 | |
ioannis@45 | 885 | def setup_upload_file(parser): |
ioannis@45 | 886 | """ Upload but do not monitor processing progress. """ |
ioannis@45 | 887 | def upload_file_from_args(parsed): |
ioannis@45 | 888 | process_file(parsed.filename, parsed.system, parsed.config, |
ioannis@45 | 889 | monitor=parsed.process, |
ioannis@45 | 890 | force_upload=parsed.force_upload, |
ioannis@45 | 891 | delete_related=False, # For now, use this as default |
ioannis@32 | 892 | rs_filename=parsed.radiosounding, |
ioannis@32 | 893 | ov_filename=parsed.overlap, |
ioannis@32 | 894 | lr_filename=parsed.lidarratio) |
moritz@29 | 895 | |
moritz@29 | 896 | parser.add_argument("filename", help="Measurement file name or path.") |
moritz@29 | 897 | parser.add_argument("system", help="Processing system id.") |
ioannis@45 | 898 | parser.add_argument("-p", "--process", help="Wait for the processing results.", |
ioannis@45 | 899 | action="store_true") |
ioannis@45 | 900 | parser.add_argument("--force_upload", help="If measurement ID exists on SCC, delete before uploading.", |
ioannis@45 | 901 | action="store_true") |
i@30 | 902 | parser.add_argument("--radiosounding", default=None, help="Radiosounding file name or path") |
ioannis@32 | 903 | parser.add_argument("--overlap", default=None, help="Overlap file name or path") |
ioannis@32 | 904 | parser.add_argument("--lidarratio", default=None, help="Lidar ratio file name or path") |
i@30 | 905 | |
moritz@29 | 906 | parser.set_defaults(execute=upload_file_from_args) |
moritz@29 | 907 | |
moritz@29 | 908 | |
moritz@29 | 909 | def setup_list_measurements(parser): |
moritz@29 | 910 | def list_measurements_from_args(parsed): |
ioannis@45 | 911 | # TODO: Fix this |
ioannis@45 | 912 | logger.warning("This method needs to be updated. Cross-chceck any results.") |
ioannis@45 | 913 | |
moritz@29 | 914 | list_measurements(parsed.config, station=parsed.station, system=parsed.system, start=parsed.start, |
moritz@29 | 915 | stop=parsed.stop, |
moritz@29 | 916 | upload_status=parsed.upload_status, preprocessing_status=parsed.preprocessing_status, |
moritz@29 | 917 | optical_processing=parsed.optical_processing_status) |
moritz@29 | 918 | |
moritz@29 | 919 | def status(arg): |
moritz@29 | 920 | if -127 <= int(arg) <= 127: |
moritz@29 | 921 | return arg |
moritz@29 | 922 | else: |
moritz@29 | 923 | raise argparse.ArgumentTypeError("Status must be between -127 and 127") |
moritz@29 | 924 | |
moritz@29 | 925 | def date(arg): |
moritz@29 | 926 | if re.match(r'\d{4}-\d{2}-\d{2}', arg): |
moritz@29 | 927 | return arg |
moritz@29 | 928 | else: |
moritz@29 | 929 | raise argparse.ArgumentTypeError("Date must be in format 'YYYY-MM-DD'") |
moritz@29 | 930 | |
moritz@29 | 931 | parser.add_argument("--station", help="Filter for only the selected station") |
moritz@29 | 932 | parser.add_argument("--system", help="Filter for only the selected station") |
moritz@29 | 933 | parser.add_argument("--start", help="Filter for only the selected station", type=date) |
moritz@29 | 934 | parser.add_argument("--stop", help="Filter for only the selected station", type=date) |
moritz@29 | 935 | parser.add_argument("--upload-status", help="Filter for only the selected station", type=status) |
moritz@29 | 936 | parser.add_argument("--preprocessing-status", help="Filter for only the selected station", type=status) |
moritz@29 | 937 | parser.add_argument("--optical-processing-status", help="Filter for only the selected station", type=status) |
moritz@29 | 938 | parser.set_defaults(execute=list_measurements_from_args) |
moritz@29 | 939 | |
moritz@29 | 940 | |
moritz@29 | 941 | def setup_download_measurements(parser): |
moritz@29 | 942 | def download_measurements_from_args(parsed): |
ioannis@45 | 943 | # TODO: Fix this |
ioannis@45 | 944 | logger.warning("This method needs to be updated. Cross-chceck any results.") |
ioannis@45 | 945 | |
ioannis@45 | 946 | preproc = parsed.download_elpp |
ioannis@45 | 947 | optical = parsed.download_elda |
moritz@29 | 948 | graphs = parsed.download_profile_graphs |
moritz@29 | 949 | if not preproc and not graphs: |
moritz@29 | 950 | optical = True |
moritz@29 | 951 | download_measurements(parsed.IDs, preproc, optical, graphs, parsed.config) |
moritz@29 | 952 | |
moritz@29 | 953 | parser.add_argument("IDs", help="Measurement IDs that should be downloaded.", nargs="+") |
moritz@29 | 954 | parser.add_argument("--download-preprocessed", action="store_true", help="Download preprocessed files.") |
moritz@29 | 955 | parser.add_argument("--download-optical", action="store_true", |
moritz@29 | 956 | help="Download optical files (default if no other download is used).") |
moritz@29 | 957 | parser.add_argument("--download-profile-graphs", action="store_true", help="Download profile graph files.") |
moritz@29 | 958 | parser.set_defaults(execute=download_measurements_from_args) |
moritz@29 | 959 | |
moritz@29 | 960 | |
victor@7 | 961 | def main(): |
victor@7 | 962 | # Define the command line arguments. |
victor@7 | 963 | parser = argparse.ArgumentParser() |
moritz@29 | 964 | subparsers = parser.add_subparsers() |
moritz@29 | 965 | |
moritz@29 | 966 | delete_parser = subparsers.add_parser("delete", help="Deletes a measurement.") |
ioannis@45 | 967 | rerun_all_parser = subparsers.add_parser("rerun-all", help="Rerun all processing steps for the provided measurement IDs.") |
ioannis@45 | 968 | rerun_processing_parser = subparsers.add_parser("rerun-elpp", |
ioannis@45 | 969 | help="Rerun low-resolution processing steps for the provided measurement ID.") |
ioannis@45 | 970 | upload_file_parser = subparsers.add_parser("upload-file", help="Submit a file and, optionally, download the output products.") |
ioannis@32 | 971 | list_parser = subparsers.add_parser("list", help="List measurements registered on the SCC.") |
moritz@29 | 972 | download_parser = subparsers.add_parser("download", help="Download selected measurements.") |
moritz@29 | 973 | |
moritz@29 | 974 | setup_delete(delete_parser) |
moritz@29 | 975 | setup_rerun_all(rerun_all_parser) |
ioannis@45 | 976 | setup_rerun_elpp(rerun_processing_parser) |
ioannis@45 | 977 | |
moritz@29 | 978 | setup_upload_file(upload_file_parser) |
moritz@29 | 979 | setup_list_measurements(list_parser) |
moritz@29 | 980 | setup_download_measurements(download_parser) |
victor@7 | 981 | |
victor@7 | 982 | # Verbosity settings from http://stackoverflow.com/a/20663028 |
victor@7 | 983 | parser.add_argument('-d', '--debug', help="Print debugging information.", action="store_const", |
victor@7 | 984 | dest="loglevel", const=logging.DEBUG, default=logging.INFO, |
victor@7 | 985 | ) |
victor@7 | 986 | parser.add_argument('-s', '--silent', help="Show only warning and error messages.", action="store_const", |
victor@7 | 987 | dest="loglevel", const=logging.WARNING |
victor@7 | 988 | ) |
victor@7 | 989 | |
ioannis@32 | 990 | # Setup default config location |
moritz@29 | 991 | home = os.path.expanduser("~") |
moritz@29 | 992 | default_config_location = os.path.abspath(os.path.join(home, ".scc_access.yaml")) |
moritz@29 | 993 | parser.add_argument("-c", "--config", help="Path to the config file.", type=settings_from_path, |
moritz@29 | 994 | default=default_config_location) |
victor@7 | 995 | |
victor@7 | 996 | args = parser.parse_args() |
ioannis@43 | 997 | |
victor@7 | 998 | # Get the logger with the appropriate level |
victor@7 | 999 | logging.basicConfig(format='%(levelname)s: %(message)s', level=args.loglevel) |
victor@7 | 1000 | |
moritz@29 | 1001 | # Dispatch to appropriate function |
moritz@29 | 1002 | args.execute(args) |
moritz@29 | 1003 | |
i@14 | 1004 | |
moritz@29 | 1005 | # When running through terminal |
moritz@29 | 1006 | if __name__ == '__main__': |
moritz@29 | 1007 | main() |