src/java/python_Scripts/erosionServiceCall.py
| @@ -13,11 +13,15 @@ |
| |
| def extract_json_key_value(json_list, key='cokey', value='value'): |
| try: |
| - return [ el[value] for el in json_list if el['name'] == key ][0] |
| + for el in json_list: |
| + try: |
| + if el['name'] == key: |
| + return el[value] |
| + except KeyError as ke: |
| + continue |
| + raise ValueError(f"{key} not present: " + e) |
| except Exception as e: |
| - logging.error(f"{key} not present: " + e) |
| return None |
| - # raise ValueError(f"{key} not present: " + e) |
| |
| class Results: |
| def __init__(self, idx, lat, lon): |
| @@ -370,8 +374,8 @@ |
| |
| ## service attempts |
| max_attempts = 4 |
| -# repo_basepath = '/home/daniele/documents/codebeamer/csip-crp1/' |
| -repo_basepath = '/home/eramscloud/vcs/hg/csip/csip-crp1/' |
| +repo_basepath = '/home/daniele/documents/codebeamer/csip-crp1/' |
| +# repo_basepath = '/home/eramscloud/vcs/hg/csip/csip-crp1/' |
| ## reference datetime for log and results |
| ref_datetime = dt.datetime.now() |
| |
| @@ -388,12 +392,12 @@ |
| output_failed = '''{repo_basepath}data/{datetime:%Y%m%dT%H%M%S}_failed.csv'''.format(repo_basepath=repo_basepath, datetime=ref_datetime) |
| |
| #read coordinates csv file |
| -d = pd.read_csv('''{repo_basepath}data/20230517T155328_failed.csv'''.format(repo_basepath=repo_basepath)) |
| -# d = pd.read_csv('''{repo_basepath}data/test.csv'''.format(repo_basepath=repo_basepath)) |
| +# d = pd.read_csv('''{repo_basepath}data/20230517T155328_failed.csv'''.format(repo_basepath=repo_basepath)) |
| +d = pd.read_csv('''{repo_basepath}data/todo.csv'''.format(repo_basepath=repo_basepath)) |
| df = pd.DataFrame(data = d) |
| points_num = df.shape[0] |
| -count = cpu_count() |
| -# count = 1 |
| +# count = cpu_count() |
| +count = 1 |
| |
| manager = Manager() |
| results = manager.list() |