-
Notifications
You must be signed in to change notification settings - Fork 2
/
dsget_wrapper.sh
executable file
·815 lines (758 loc) · 28.9 KB
/
dsget_wrapper.sh
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357
358
359
360
361
362
363
364
365
366
367
368
369
370
371
372
373
374
375
376
377
378
379
380
381
382
383
384
385
386
387
388
389
390
391
392
393
394
395
396
397
398
399
400
401
402
403
404
405
406
407
408
409
410
411
412
413
414
415
416
417
418
419
420
421
422
423
424
425
426
427
428
429
430
431
432
433
434
435
436
437
438
439
440
441
442
443
444
445
446
447
448
449
450
451
452
453
454
455
456
457
458
459
460
461
462
463
464
465
466
467
468
469
470
471
472
473
474
475
476
477
478
479
480
481
482
483
484
485
486
487
488
489
490
491
492
493
494
495
496
497
498
499
500
501
502
503
504
505
506
507
508
509
510
511
512
513
514
515
516
517
518
519
520
521
522
523
524
525
526
527
528
529
530
531
532
533
534
535
536
537
538
539
540
541
542
543
544
545
546
547
548
549
550
551
552
553
554
555
556
557
558
559
560
561
562
563
564
565
566
567
568
569
570
571
572
573
574
575
576
577
578
579
580
581
582
583
584
585
586
587
588
589
590
591
592
593
594
595
596
597
598
599
600
601
602
603
604
605
606
607
608
609
610
611
612
613
614
615
616
617
618
619
620
621
622
623
624
625
626
627
628
629
630
631
632
633
634
635
636
637
638
639
640
641
642
643
644
645
646
647
648
649
650
651
652
653
654
655
656
657
658
659
660
661
662
663
664
665
666
667
668
669
670
671
672
673
674
675
676
677
678
679
680
681
682
683
684
685
686
687
688
689
690
691
692
693
694
695
696
697
698
699
700
701
702
703
704
705
706
707
708
709
710
711
712
713
714
715
716
717
718
719
720
721
722
723
724
725
726
727
728
729
730
731
732
733
734
735
736
737
738
739
740
741
742
743
744
745
746
747
748
749
750
751
752
753
754
755
756
757
758
759
760
761
762
763
764
765
766
767
768
769
770
771
772
773
774
775
776
777
778
779
780
781
782
783
784
785
786
787
788
789
790
791
792
793
794
795
796
797
798
799
800
801
802
803
804
805
806
807
808
809
810
811
812
813
814
815
#!/bin/bash
#-------------------------------------------------------------------------------------------#
# Demo script illustrating some examples using the OData interface #
# of the Data Hub Service (Ds) - previsouly Data Hub Service (DHuS) #
#-------------------------------------------------------------------------------------------#
# CHANGE LOG
# v0.3.1:
# - usage switch fixed
# - usage text updated to include the download of Sentinel 2 products
# - introduction of parallel download with check of the server error messages (option -n)
# - insertion of MD5 check
#
# Serco SpA 2015
# CHANGE LOG
# v0.3.2:
# - fixed "-f" option
# - upgraded "-f"
# - added the following options: -s, -e, -S, -E, -F
#
# CHANGE LOG
# v0.3.3:
# - added the following options: -O, -L, -R, -r
#
# CHANGE LOG
# v0.3.4:
# - added the following options: -m, -i, -l, -P, -q, -C, -N, -D
#
# Serco SpA 2015
#
#CHANGE LOG
#v0.3.5:
# -changed "==" with "=" in the MD5 check section
#
#CHANGE LOG
#v0.3.6
# - added Sentinel-5 P references
# - changed "==" with "=" in the MD5 check section [line 818]
# - added CheckSum Echo
#
#CHANGE LOG
#v0.3.7
# - fix download of ".NetCDF" file
# #
#CHANGE LOG
#v0.3.8
# - added management of offline products download
#
#CHANGE LOG
#v0.3.9
# - translated Copernicus scihub OData (Open Data Protocol) to
# Copernicus dataspace OData
# (see https://scihub.copernicus.eu/news/News01249)
#
#------------------------------------------------------------------------------------------- #
export VERSION=0.3.9
WD=dsget_tmp
PIDFILE=$WD/pid
test -d $WD || mkdir -p $WD
#-
bold=$(tput bold)
normal=$(tput sgr0)
print_script=$(echo "$0" | rev | cut -d'/' -f1 | rev)
function print_usage {
print_script=$(echo "$1" | rev | cut -d'/' -f1 | rev)
echo " "
echo "${bold}NAME${normal}"
echo " "
echo " Dsget $VERSION - The non interactive Sentinels product retriever from the Sentinels Data Hubs"
echo " "
echo "${bold}USAGE${normal}"
echo " "
echo " $print_script [LOGIN OPTIONS]... [SEARCH QUERY OPTIONS]... [SEARCH RESULT OPTIONS]... [DOWNLOAD OPTIONS]... "
echo " "
echo "${bold}DESCRIPTION${normal}"
echo " "
echo " This script allows to get products from Sentinels Data Hubs executing query with different filter. The products can be visualized on shell and saved in list file"
echo " or downloaded in a zip file."
echo " Recommendation: If this script is run as a cronjob, to avoid traffic load, please do not schedule it exactly at on-the-clock hours (e.g 6:00, 5:00)."
echo " "
echo "${bold}OPTIONS"
echo " "
echo " ${bold}LOGIN OPTIONS:${normal}"
echo " "
echo " -d <Ds URL> : specify the URL of the Data Hub Service;"
echo " -u <username> : data hub username;"
echo " -p <password> : data hub password (note: if not provided by command line it is read by stdin);"
echo " "
echo " "
echo " ${bold}SEARCH QUERY OPTIONS:${normal}"
echo " "
echo " -m <mission name> : Sentinel mission name. Possible options are: Sentinel-1, Sentinel-2, Sentinel-3, Sentinel-5 P);"
echo ""
echo " -i <instrument name> : instrument name. Possible options are: SAR, MSI, OLCI, SLSTR, SRAL, TROPOMI);"
echo ""
echo " -t <time in hours> : search for products ingested in the last <time in hours> (integer) from the time of"
echo " execution of the script."
echo " (e.g. '-t 24' to search for products ingested in the last 24 Hours);"
echo ""
echo " -s <ingestion_date_FROM> : Search for products ingested ${bold}after${normal} the date and time specified by <ingestion_date_FROM>."
echo " The date format is ISO 8601, YYYY-MM-DDThh:mm:ss.cccZ (e.g. -s 2016-10-02T06:00:00.000Z);"
echo ""
echo " -e <ingestion_date_TO> : Search for products ingested ${bold}before${normal} the date specified by <ingestion_date_TO>."
echo " The date format is ISO 8601, YYYY-MM-DDThh:mm:ss.cccZ (e.g. -e 2016-10-10T12:00:00.000Z);"
echo ""
echo " -S <sensing_date_FROM> : Search for products with sensing date ${bold}greater than${normal} the date and time specified by <sensing_date_FROM>."
echo " The date format is ISO 8601, YYYY-MM-DDThh:mm:ss.cccZ (e.g. -S 2016-10-02T06:00:00.000Z);"
echo ""
echo " -E <sensing_date_TO> : Search for products with sensing date ${bold}less than${normal} the date and time specified by <sensing_date_TO>."
echo " The date format is ISO 8601, YYYY-MM-DDThh:mm:ss.cccZ (e.g. -E 2016-10-10T12:00:00.000Z);"
echo ""
echo " -f <ingestion_date_file> : Search for products ingested after the date and time provided through an input file. This option overrides option -s"
echo " The date format shall be ISO 8601 (YYYY-MM-DDThh:mm:ss.cccZ)."
echo " <ingestion_date_file> is automatically updated at the end of the script execution"
echo " with the ingestion date of the last sucessfully downloaded product;"
echo " "
echo " -c <lon1,lat1:lon2,lat2> : Search for products intersecting a rectangular Area of Interst (or Bounding Box)"
echo " by providing the geographical coordinates of two opposite vertices. "
echo " Coordinates need to be provided in Decimal Degrees and with the following syntax:"
echo " "
echo " - ${bold}lon1,lat1:lon2,lat2${normal}"
echo " "
echo " where lon1 and lat1 are respectively the longitude and latitude of the first vertex and"
echo " lon2 and lat2 the longitude and latitude of the second vertex."
echo " (e.g. '-c -4.530,29.850:26.750,46.800' is a bounding box enclosing the Mediterranean Sea);"
echo " "
echo " -T <product type> : Search products according to the specified product type."
echo " Sentinel-1 possible options are: SLC, GRD, OCN and RAW. "
echo " Sentinel-2 posiible option is: S2MSI1C ;"
echo " Sentinel-5 P possible options are: RA, IR, O3, NO2, CO, CLOUD, AER and NP. "
echo " "
echo " -F <free OpenSearch query> : free text OpenSearch query. The query must be written enclosed by single apexes '<query>'. "
echo " (e.g. -F 'platformname:Sentinel-1 AND producttype:SLC'). "
echo " (e.g. -F 'platformname:Sentinel-5 P AND producttype:RA'). "
echo " Note: the free text OpenSearch query is in ${bold}AND${normal} with the other possible sspecified search options."
echo " "
echo " "
echo " ${bold}SEARCH RESULT OPTIONS:${normal}"
echo " "
echo " -l <results> : maximum number of results per page [1,2,3,4,..]; default value = 25"
echo " "
echo " -P <page> : page number [1,2,3,4,..]; default value = 1"
echo " "
echo " -q <XMLfile> : write the OpenSearch query results in a specified XML file. Default file is './OSquery-result.xml'"
echo " "
echo " -C <CSVfile> : write the list of product results in a specified CSV file. Default file is './products-list.csv'"
echo " "
echo " "
echo " ${bold}DOWNLOAD OPTIONS:${normal}"
echo " "
echo " -o <download> : THIS OPTION IS MANDATORY FOR DOWNLOADING. Accepted values for <download> are:"
echo " - ${bold}product${normal} : download the Product ZIP files (manifest file included)"
echo " - ${bold}manifest${normal} : download only the manifest files"
echo " - ${bold}all${normal} : download both the Product ZIP files and the manifest files, and"
echo " provide them in separate folders."
echo ""
echo " By default the Product ZIP files are stored in ./product"
echo " unless differently specified by option ${bold}-O${normal}."
echo ""
echo " By default the manifest files are stored in ./manifest ;"
echo " "
echo " "
echo " -O <folder> : save the Product ZIP files in a specified folder. "
echo " "
echo " -N <1...n> : set number of wget download retries. Default value is 5. Fatal errors like 'connection refused'"
echo " or 'not found' (404), are not retried;"
echo " "
echo " -R <file> : write in <file> the list of products that have failed the MD5 integrity check."
echo " By default the list is written in ./failed_MD5_check_list.txt ;"
echo " The format of the output file is compatible with option ${bold}-r${normal} ;"
echo " "
echo " -D : if specified, remove the products that have failed the MD5 integrity check from disk."
echo " By deafult products are not removed;"
echo " "
echo " -r <file> : download the products listed in an input <file> written according to the following format:"
echo " - One product per line."
echo " - <space><one character><space><UUID><space><one character><space><filename>."
echo " Examples:"
echo " ' x 67c7491a-d98a-4eeb-9ca0-8952514c7e1e x S1A_EW_GRDM_1SSH_20160411T113221_20160411T113257_010773_010179_7BE0'"
echo " ' 0 67c7491a-d98a-4eeb-9ca0-8952514c7e1e 0 S1A_EW_GRDM_1SSH_20160411T113221_20160411T113257_010773_010179_7BE0'"
echo " "
echo " -L <lock folder> : by default only one instance of dsget can be executed at a time. This is ensured by the creation"
echo " of a temporary lock folder $HOME/dsget_tmp/lock which is removed a the end of each run."
echo " For running more than one dsget instance at a time is sufficient to assign different lock folders"
echo " using the -L option (e.g. '-L foldername') to each dsget instance;"
echo " "
echo " -n <1...n> : number of concurrent downloads (either products or manifest files). Default value is 2; this value"
echo " doesn't override the quota limit set on the server side for the user"
echo " "
echo " -w <1...n> : minutes to wait until retrying the download of an offline product. Default value is 10;"
echo " "
echo " "
echo " -W <1...n> : number of download retries for offline products. Default value is 40."
echo " "
echo " "
echo " 'wget' is necessary to run the dsget"
echo " "
exit -1
}
function print_version {
echo "dsget $VERSION"
exit -1
}
#------------------------------------------------------------------------------
#--- added methods and variables for offline product download management BEGIN
#------------------------------------------------------------------------------
export OFFLINE_PRODUCT_LIST=offline_product_list.txt
export TMP_OFFLINE_PRODUCT_LIST=offline_product_list.csv
export OFFLINE_RETRY_ATTEMPTS_COUNTER=0
# export -f add_offline_product_to_list
function download_product {
cat $1 | xargs -n 4 -P $2 sh -c ' while : ; do
echo "Downloading product ${3} from link ${DS_DEST}/odata/v1/Products('\''"$1"'\'')/\$value";
# ---added control on S5P products
prod5P=${3}
mission5P="S5P"
if echo $prod5P | grep -q "$mission5P"; then
${WC} ${AUTH} ${TRIES} --progress=dot -e dotbytes=10M -c --output-file=./logs/log.${3}.log -O $output_folder/${3}".nc" "${DS_DEST}/odata/v1/Products('\''"$1"'\'')/\$value";
else
${WC} ${AUTH} ${TRIES} --progress=dot -e dotbytes=10M -c --output-file=./logs/log.${3}.log -O $output_folder/${3}".zip" "${DS_DEST}/odata/v1/Products('\''"$1"'\'')/\$value";
fi
test=$?;
# --- check HTTP response status in case of offline products download
http_response=`cat ./logs/log.${3}.log| grep '\''403 Forbidden\|202 Accepted\|503 Service Unavailable'\''`;
echo "http_response is $http_response";
if [ ! -z "$http_response" ]; then
echo "The requested product is offline" ;
echo "Adding product ${3} in the offline product download queue" ;
echo "${2},${1},${3}" | tee -a "${TMP_OFFLINE_PRODUCT_LIST}" ;
else
if [ $test -eq 0 ]; then
echo "Product ${3} successfully downloaded at " `tail -2 ./logs/log.${3}.log | head -1 | awk -F"(" '\''{print $2}'\'' | awk -F")" '\''{print $1}'\''`;
remoteMD5=$( ${WC} -qO- ${AUTH} ${TRIES} -c "${DS_DEST}/odata/v1/Products('\''"$1"'\'')/Checksum/Value/$value" | awk -F">" '\''{print $3}'\'' | awk -F"<" '\''{print $1}'\'');
if echo $prod5P | grep -q "$mission5P"; then
localMD5=$( openssl md5 $output_folder/${3}".nc" | awk '\''{print $2}'\'');
else
localMD5=$( openssl md5 $output_folder/${3}".zip" | awk '\''{print $2}'\'');
fi
localMD5Uppercase=$(echo "$localMD5" | tr '\''[:lower:]'\'' '\''[:upper:]'\'');
#localMD5Uppercase=1;
if [ "$remoteMD5" = "$localMD5Uppercase" ]; then
echo "Product ${3} successfully MD5 checked";
echo "Remote MD5: $remoteMD5"
echo "Local MD5: $localMD5Uppercase"
else
echo "Checksum for product ${3} failed";
echo "${0} ${1} ${2} ${3}" >> .failed.control.now.txt;
if [ ! -z $save_products_failed ];then
rm $output_folder/${3}".zip"
fi
fi;
else
echo "${0} ${1} ${2} ${3}" >> .failed.control.now.txt;
if [ ! -z $save_products_failed ];then
rm $output_folder/${3}".zip"
fi
fi;
fi;
break;
done '
}
#------------------------------------------------------------------------------
#--- added methods and variables for offline product download management END
#------------------------------------------------------------------------------
#----------------------
#--- Load input parameter
export DS_DEST="https://catalogue.dataspace.copernicus.eu/odata/v1"
export USERNAME=""
export PASSWORD=""
export TIME_SUBQUERY=""
export PRODUCT_TYPE=""
export INGEGESTION_TIME_FROM="1970-01-01T00:00:00.000Z"
export INGEGESTION_TIME_TO="NOW"
export SENSING_TIME_FROM="1970-01-01T00:00:00.000Z"
export SENSING_TIME_TO="NOW"
unset TIMEFILE
while getopts ":d:u:p:l:P:q:C:m:i:t:s:e:S:E:f:c:T:o:V:h:F:R:D:r:O:N:L:n:w:W:" opt; do
case $opt in
d)
export DS_DEST="$OPTARG"
export DS_DEST_IS_SET='OK'
;;
u)
export USERNAME="$OPTARG"
;;
p)
export PASSWORD="$OPTARG"
;;
l)
export ROWS="$OPTARG"
;;
P)
export PAGE="$OPTARG"
;;
q)
export NAMEFILERESULTS="$OPTARG"
;;
C)
export PRODUCTLIST="$OPTARG"
;;
m)
export MISSION="$OPTARG"
;;
i)
export INSTRUMENT="$OPTARG"
;;
t)
export TIME="$OPTARG"
export INGEGESTION_TIME_FROM="NOW-${TIME}HOURS"
export isselected_filtertime_lasthours='OK'
;;
s)
export TIME="$OPTARG"
export INGEGESTION_TIME_FROM="$OPTARG"
export isselected_filtertime_ingestion_date='OK'
;;
e)
export TIME="$OPTARG"
export INGEGESTION_TIME_TO="$OPTARG"
export isselected_filtertime_ingestion_date='OK'
;;
S)
export SENSING_TIME="$OPTARG"
export SENSING_TIME_FROM="$OPTARG"
;;
E)
export SENSING_TIME="$OPTARG"
export SENSING_TIME_TO="$OPTARG"
;;
f)
export TIMEFILE="$OPTARG"
if [ -s $TIMEFILE ]; then
export INGEGESTION_TIME_FROM="$(cat $TIMEFILE)"
else
export INGEGESTION_TIME_FROM="1970-01-01T00:00:00.000Z"
fi
;;
c)
ROW=$OPTARG
FIRST=$(echo "$ROW" | awk -F\: '{print \$1}')
SECOND=$(echo "$ROW" | awk -F\: '{print \$2}')
#--
export x1=$(echo ${FIRST} | awk -F, '{print $1}')
export y1=$(echo ${FIRST} | awk -F, '{print $2}')
export x2=$(echo ${SECOND} | awk -F, '{print $1}')
export y2=$(echo ${SECOND} | awk -F, '{print $2}')
;;
T)
export PRODUCT_TYPE="$OPTARG"
;;
o)
export TO_DOWNLOAD="$OPTARG"
;;
V)
print_version $0
;;
h)
print_usage $0
;;
F)
FREE_SUBQUERY_CHECK="OK"
FREE_SUBQUERY="$OPTARG"
;;
R)
export FAILED="$OPTARG"
export check_save_failed='OK'
;;
D)
export save_products_failed='OK'
;;
r)
export FAILED_retry="$OPTARG"
export check_retry='OK'
;;
O)
export output_folder="$OPTARG"
export OUTPUT_FOLDER_IS_SET='OK'
;;
N)
export number_tries="$OPTARG"
;;
L)
export lock_file="$OPTARG"
export LOCK_FILE_IS_SET='OK'
;;
n)
export THREAD_NUMBER="$OPTARG"
export THREAD_NUMBER_IS_SET='OK'
;;
w)
export OFFLINE_WAIT="${OPTARG}m"
;;
W)
export OFFLINE_RETRY_ATTEMPTS="$OPTARG"
;;
esac
done
echo ""
echo "================================================================================================================"
echo ""
echo "dsget version: $VERSION"
echo ""
echo "USAGE: $print_script [LOGIN OPTIONS]... [SEARCH QUERY OPTIONS]... [SEARCH RESULT OPTIONS]... [DOWNLOAD OPTIONS]... "
echo ""
echo "Type '$print_script -help' for usage information"
echo ""
echo "================================================================================================================"
ISSELECTEDEXIT=false
trap ISSELECTEDEXIT=true INT
if [ -z $lock_file ]; then
export lock_file="$WD/lock"
fi
mkdir $lock_file
if [ ! $? == 0 ]; then
echo -e "Error! An instance of \"dsget\" retriever is running !\n Pid is: "$(cat ${PIDFILE}) "if it isn't running delete the lockdir ${lock_file}"
exit
else
echo $$ >$PIDFILE
fi
trap "rm -fr ${lock_file}" EXIT
export TIME_SUBQUERY="ingestiondate:[$INGEGESTION_TIME_FROM TO $INGEGESTION_TIME_TO] "
export SENSING_SUBQUERY="ContentDate/Start gt $SENSING_TIME_FROM and ContentDate/Start lt $SENSING_TIME_TO "
if [ -z $THREAD_NUMBER ]; then
export THREAD_NUMBER="2"
fi
if [ -z $output_folder ]; then
export output_folder="PRODUCT"
fi
export WC="wget --no-check-certificate --continue -nc"
echo "LOGIN"
printf "\n"
if [ -z $DS_DEST_IS_SET ]; then
echo "'-d option' not specified. "
echo "Default Data Space Service URL is: "
else
echo "Specified Data Space Service URL is:"
fi
echo $DS_DEST
printf "\n"
if [ ! -z $USERNAME ] && [ -z $PASSWORD ]; then
echo "You have inserted only USERNAME"
echo ""
fi
if [ -z $USERNAME ] && [ ! -z $PASSWORD ]; then
echo "You have inserted only PASSWORD"
echo ""
fi
if [ -z $USERNAME ]; then
read -p "Enter username: " VAL
printf "\n"
export USERNAME=${VAL}
fi
if [ -z $PASSWORD ]; then
read -s -p "Enter password: " VAL
printf "\n\n"
export PASSWORD=${VAL}
fi
export AUTH="--user=${USERNAME} --password=${PASSWORD}"
if [ -z $number_tries ]; then
export TRIES="--tries=5"
else
export TRIES="--tries=${number_tries}"
fi
mkdir -p './logs/'
if [ ! -z $check_retry ] && [ -s $FAILED_retry ]; then
cp $FAILED_retry .failed.control.retry.now.txt
export INPUT_FILE=.failed.control.retry.now.txt
mkdir -p $output_folder
if [ -f .failed.control.now.txt ]; then
rm .failed.control.now.txt
fi
cat ${INPUT_FILE} | xargs -n 4 -P ${THREAD_NUMBER} sh -c ' while : ; do
echo "Downloading product ${3} from link ${DS_DEST}/odata/v1/Products('\''"$1"'\'')/\$value";
${WC} ${AUTH} ${TRIES} --progress=dot -e dotbytes=10M -c --output-file=./logs/log.${3}.log -O $output_folder/${3}".zip" "${DS_DEST}/odata/v1/Products('\''"$1"'\'')/\$value";
test=$?;
if [ $test -eq 0 ]; then
echo "Product ${3} successfully downloaded at " `tail -2 ./logs/log.${3}.log | head -1 | awk -F"(" '\''{print $2}'\'' | awk -F")" '\''{print $1}'\''`;
remoteMD5=$( ${WC} -qO- ${AUTH} ${TRIES} -c "${DS_DEST}/odata/v1/Products('\''"$1"'\'')/Checksum/Value/$value" | awk -F">" '\''{print $3}'\'' | awk -F"<" '\''{print $1}'\'');
localMD5=$( openssl md5 $output_folder/${3}".zip" | awk '\''{print $2}'\'');
localMD5Uppercase=$(echo "$localMD5" | tr '\''[:lower:]'\'' '\''[:upper:]'\'');
echo "Remote MD5: $remoteMD5"
echo "Local MD5: $localMD5Uppercase"
if [ "$remoteMD5" = "$localMD5Uppercase" ]; then
echo "Product ${3} successfully MD5 checked";
else
echo "Checksum for product ${3} failed";
echo "${0} ${1} ${2} ${3}" >> .failed.control.now.txt;
if [ ! -z $save_products_failed ];then
rm $output_folder/${3}".zip"
fi
fi;
else
echo "${0} ${1} ${2} ${3}" >> .failed.control.now.txt;
if [ ! -z $save_products_failed ];then
rm $output_folder/${3}".zip"
fi
fi;
break;
done '
rm .failed.control.retry.now.txt
fi
#----- Options value check
echo "================================================================================================================"
echo ""
echo "SEARCH QUERY OPTIONS"
if [ -z $TIME ] && [ -z $TIMEFILE ] && [ -z $ROW ] && [ -z $PRODUCT_TYPE ] && [ -z $FREE_SUBQUERY_CHECK ] && [ -z $SENSING_TIME ] && [ -z $MISSION ] && [ -z $INSTRUMENT ]; then
echo ""
echo "No Search Options specified. Default query is q='*'."
echo ""
export QUERY_STATEMENT="*"
else
echo ""
fi
if [ -z $MISSION ]; then
echo "'-m option' not specified. Search is performed on all available sentinel missions."
echo ""
else
echo "'-m option' mission is set to $MISSION. "
echo ""
fi
if [[ -z $INSTRUMENT ]]; then
echo "'-i option' not specified. Search is performed on all available instruments."
echo ""
else
echo "'-i option' instrument is set to $INSTRUMENT. "
echo ""
fi
if [ -z $TIME ]; then
echo " Ingestion date options not specified ('-t', '-s', '-e'). "
echo ""
else
if [ ! -z $isselected_filtertime_ingestion_date ] && [ ! -z $isselected_filtertime_lasthours ]; then
if [ -z $TIMEFILE ]; then
echo "'-s option' and '-e option' are set to $INGEGESTION_TIME_FROM and $INGEGESTION_TIME_TO. Search is performed for all products ingested in the period [$INGEGESTION_TIME_FROM,$INGEGESTION_TIME_TO]. "
echo ""
else
echo "'-f option' is specified. Search is performed for all products ingested in the period [$INGEGESTION_TIME_FROM,$INGEGESTION_TIME_TO]. "
echo ""
fi
else
if [ ! -z $isselected_filtertime_lasthours ]; then
if [ -z $TIMEFILE ]; then
echo "'-t option' is set to $TIME. Search is performed for all products ingested in the last $TIME hours. "
echo ""
fi
else
echo "'-s option' and '-e option' are set to $INGEGESTION_TIME_FROM and $INGEGESTION_TIME_TO. Search is performed for all products ingested in the period [$INGEGESTION_TIME_FROM,$INGEGESTION_TIME_TO]. "
echo ""
fi
fi
fi
if [ -z $SENSING_TIME ]; then
echo " Sensing date options not specified ('-S', '-E')."
echo ""
else
echo "'-S option' and '-E option' are set to $SENSING_TIME_FROM and $SENSING_TIME_TO. Search for all products having sensing date included in [$SENSING_TIME_FROM,$SENSING_TIME_TO]. "
echo ""
fi
if [ ! -z $TIMEFILE ] && [ -z $isselected_filtertime_ingestion_date ]; then
echo "'-f option' is set to $TIMEFILE. The ingestion date provided through $TIMEFILE is used to search all products ingested in the period [DATEINGESTION,NOW]. The file is updated with the ingestion date of the last available product found. "
echo ""
fi
if [ -z $ROW ]; then
echo "'-c option' not specified. No specified Area of Interest. Search is performed on the whole globe."
echo ""
else
echo "'-c option' is set to $x1,$y1:$x2,$y2. Search is performed on an Area of interest defined as a bounding box delimited by the two opposite vertices P1=[lon1=$x1,lat1=$y1] and P2=[lon2=$x2,lat2=$y2]. "
echo ""
fi
if [ -z $PRODUCT_TYPE ]; then
echo "'-T option' not specified. Search is performed on all available product types. "
echo ""
else
echo "'-T option' product type is set to $PRODUCT_TYPE. "
echo ""
fi
if [ ! -z $FREE_SUBQUERY_CHECK ]; then
echo "'-F option' is set to $FREE_SUBQUERY. This OpenSearch query will be in AND with other search options. "
echo ""
fi
echo "SEARCH RESULT OPTIONS"
echo ""
if [ -z $ROWS ]; then
echo "'-l option' not specified. Default Maximum Number of Results per page is 25. "
echo ""
else
echo "'-l option' is set to $ROWS. The number of results per page is $ROWS. "
echo ""
fi
if [ -z $PAGE ]; then
echo "'-P option' not specified. Default Page Number is 1. "
echo ""
else
echo "'-P option' is set to $PAGE. The page visualized is $PAGE. "
echo ""
fi
if [ -z $NAMEFILERESULTS ]; then
echo "'-q option' not specified. OpenSearch results are stored by default in ./OSquery-result.xml. "
echo ""
else
echo "'-q option' is set to $NAMEFILERESULTS. OpenSearch results are stored in $NAMEFILERESULTS. "
echo ""
fi
if [ -z $PRODUCTLIST ]; then
echo "'-C option' not specified. List of results are stored by default in the CSV file ./products-list.csv. "
echo ""
else
echo "'-C option' is set to $PRODUCTLIST. List of results are stored in the specified CSV file $PRODUCTLIST. "
echo ""
fi
if [ ! -z $TO_DOWNLOAD ] || [ ! -z $check_retry ]; then
CHECK_VAR=true
else
CHECK_VAR=false
fi
echo "DOWNLOAD OPTIONS"
echo ""
if [ $CHECK_VAR == false ]; then
echo "No download options specified. No files will be downloaded. "
echo ""
fi
if [ ! -z $TO_DOWNLOAD ]; then
if [ $TO_DOWNLOAD=="product" ]; then
echo "'-o option' is set to $TO_DOWNLOAD. Downloads are active. By default product downloads are stored in ./PRODUCT unless differently specified by the '-O option'. "
echo ""
else
if [ $TO_DOWNLOAD=="manifest" ]; then
echo "'-o option' is set to $TO_DOWNLOAD. Only manifest files are downloaded. Manifest files are stored in ./manifest. "
echo ""
else
echo "'-o option' is set to $TO_DOWNLOAD. Downloads are active. Products and manifest files are downloded separately. "
echo ""
fi
fi
fi
if [[ $CHECK_VAR == true && ! -z $OUTPUT_FOLDER_IS_SET ]]; then
echo "'-O option' is set to $output_folder. Product downloads are stored in ./$output_folder. "
echo ""
fi
if [[ $CHECK_VAR == true && -z $number_tries ]]; then
echo "'-N option' not specified. By default the number of wget download retries is 5. "
echo ""
else
if [[ $CHECK_VAR == true && ! -z $number_tries ]]; then
echo "'-N option' is set to $number_tries. The number of wget download retries is $number_tries. "
echo ""
fi
fi
if [[ $CHECK_VAR == true && -z $check_save_failed ]]; then
echo "'-R option' not specified. By default the list of products failing the MD5 integrity check is saved in ./failed_MD5_check_list.txt. "
echo ""
else
if [[ $CHECK_VAR == true && ! -z $check_save_failed ]]; then
echo "'-R option' is set to $FAILED. The list of products failing the MD5 integrity check is saved in $FAILED. "
echo ""
fi
fi
if [[ $CHECK_VAR == true && ! -z $save_products_failed ]]; then
echo "'-D option' is active. Products that have failed the MD5 integrity check are deleted from the local disks. "
echo ""
fi
if [[ $CHECK_VAR == true && ! -z $check_retry ]]; then
echo "'-r option' is set to $FAILED_retry. It retries the download of the products listed in $FAILED_retry. "
echo ""
fi
if [ ! -z $LOCK_FILE_IS_SET ]; then
echo "'-L option' is set to $lock_file. This instance of dsget can be executed in parallel to other instances. "
echo ""
fi
if [[ $CHECK_VAR == true && -z $THREAD_NUMBER_IS_SET ]]; then
echo "'-n option' not specified. By default the number of concurrent downloads (either products or manifest files) is 2. "
echo ""
else
if [[ $CHECK_VAR == true && ! -z $THREAD_NUMBER_IS_SET ]]; then
echo "'-n option' is set to $THREAD_NUMBER. The number of concurrent downloads (either products or manifest files) is set to $THREAD_NUMBER. Attention, this value doesn't override the quota limit set on the server side for the user. "
echo ""
fi
fi
if [[ $CHECK_VAR == true && -z $OFFLINE_WAIT ]]; then
export OFFLINE_WAIT="10m"
fi
if [[ $CHECK_VAR == true && -z $OFFLINE_RETRY_ATTEMPTS ]]; then
export OFFLINE_RETRY_ATTEMPTS="40"
fi
echo "================================================================================================================"
echo ""
if [[ ! -z $MISSION ]]; then
if [ ! -z $QUERY_STATEMENT_CHECK ]; then
export QUERY_STATEMENT="$QUERY_STATEMENT AND "
fi
export QUERY_STATEMENT="$QUERY_STATEMENT platformname:$MISSION"
QUERY_STATEMENT_CHECK='OK'
fi
if [[ ! -z $INSTRUMENT ]]; then
if [ ! -z $QUERY_STATEMENT_CHECK ]; then
export QUERY_STATEMENT="$QUERY_STATEMENT AND "
fi
export QUERY_STATEMENT="$QUERY_STATEMENT instrumentshortname:$INSTRUMENT"
QUERY_STATEMENT_CHECK='OK'
fi
if [[ ! -z $PRODUCT_TYPE ]]; then
if [ ! -z $QUERY_STATEMENT_CHECK ]; then
export QUERY_STATEMENT="$QUERY_STATEMENT AND "
fi
export QUERY_STATEMENT="$QUERY_STATEMENT producttype:$PRODUCT_TYPE"
QUERY_STATEMENT_CHECK='OK'
fi
if [[ ! -z $TIME ]]; then
if [ ! -z $QUERY_STATEMENT_CHECK ]; then
export QUERY_STATEMENT="$QUERY_STATEMENT AND "
fi
export QUERY_STATEMENT="$QUERY_STATEMENT ${TIME_SUBQUERY}"
QUERY_STATEMENT_CHECK='OK'
fi
if [[ ! -z $SENSING_TIME ]]; then
if [ ! -z $QUERY_STATEMENT_CHECK ]; then
export QUERY_STATEMENT="$QUERY_STATEMENT AND "
fi
export QUERY_STATEMENT="$QUERY_STATEMENT${SENSING_SUBQUERY}"
QUERY_STATEMENT_CHECK='OK'
fi
if [[ ! -z $TIMEFILE ]]; then
if [ ! -z $QUERY_STATEMENT_CHECK ]; then
export QUERY_STATEMENT="$QUERY_STATEMENT AND "
fi
export QUERY_STATEMENT="$QUERY_STATEMENT ${TIME_SUBQUERY}"
QUERY_STATEMENT_CHECK='OK'
fi
if [[ ! -z $FREE_SUBQUERY_CHECK ]]; then
if [ ! -z $QUERY_STATEMENT_CHECK ]; then
export QUERY_STATEMENT="$QUERY_STATEMENT AND "
fi
export QUERY_STATEMENT="$QUERY_STATEMENT $FREE_SUBQUERY"
QUERY_STATEMENT_CHECK='OK'
fi
#---- Prepare query polygon statement
if [[ ! -z $x1 ]]; then
if [[ ! -z $QUERY_STATEMENT ]]; then
export QUERY_STATEMENT="$QUERY_STATEMENT AND "
fi
export GEO_SUBQUERY=$(
LC_NUMERIC=en_US.UTF-8
printf "( OData.CSC.Intersects(area=geography'SRID=4326;POLYGON ((%.13f %.13f,%.13f %.13f,%.13f %.13f,%.13f %.13f,%.13f %.13f )))\")" $x1 $y1 $x2 $y1 $x2 $y2 $x1 $y2 $x1 $y1
)
export QUERY_STATEMENT=${QUERY_STATEMENT}" ${GEO_SUBQUERY}"
else
export GEO_SUBQUERY=""
fi
#- ... append on query (without repl
if [[ -z $ROWS ]]; then
export ROWS=25
fi
if [[ -z $PAGE ]]; then
export PAGE=1
fi
START=$((PAGE - 1))
START=$((START * ROWS))
export QUERY_STATEMENT="${DS_DEST}/Products?\$filter="${QUERY_STATEMENT}""
echo "HTTP request done: "$QUERY_STATEMENT""