1
- # -*- coding: utf-8 -*-
1
+ # Licensed under a 3-clause BSD style license - see LICENSE.rst
2
2
"""
3
3
Main module from ESA NEOCC library. This module contains the two main
4
4
methods of the library: *query_list* and *query_object*. The information
5
5
is obtained from ESA Near-Earth Object Coordination Centre's (NEOCC) web
6
6
portal: https://neo.ssa.esa.int/.
7
-
8
- * Project: NEOCC portal Python interface
9
- * Property: European Space Agency (ESA)
10
- * Developed by: Elecnor Deimos
11
- * Author: C. Álvaro Arroyo Parejo
12
- * Issue: 2.2.0
13
- * Date: 19-08-2022
14
- * Purpose: Main module which gets NEAs data from https://neo.ssa.esa.int/
15
- * Module: core.py
16
- * History:
17
-
18
- ======== =========== ============================================
19
- Version Date Change History
20
- ======== =========== ============================================
21
- 1.0 26-02-2021 Initial version
22
- 1.1 26-03-2021 Adding new docstrings
23
- 1.2 17-05-2021 Adding new docstrings for *help*
24
- property in dataframes and *<tab>*
25
- specification for obtaining attributes.\n
26
- For orbit properties *orbit_elements*
27
- changes to *orbital_elements*.\n
28
- Adding impacted objects lists.\n
29
- Minor typos changes.
30
- 1.3 16-06-2021 Renamed module from *neocc* to *core*.\n
31
- Adding class type as for astroquery
32
- implementation.\n
33
- Define methods as static.\n
34
- 1.3.1 29-06-2021 No changes
35
- 1.4.0 29-10-2021 Adding new docstrings.\n
36
- Change method for obtaining physical
37
- properties
38
- 2.0.0 21-01-2022 Prepare module for Astroquery integration
39
- 2.1.0 01-03-2022 Remove *parse* dependency
40
- 2.2.0 19-08-2022 Impacted objects list format change
41
- ======== =========== ============================================
42
-
43
-
44
- © Copyright [European Space Agency][2022]
45
- All rights reserved
46
7
"""
47
8
48
9
import time
54
15
55
16
__all__ = ['neocc' , 'ESAneoccClass' ]
56
17
18
+
57
19
@async_to_sync
58
20
class ESAneoccClass (BaseQuery ):
59
21
"""
@@ -92,13 +54,13 @@ def query_list(list_name):
92
54
93
55
Returns
94
56
-------
95
- neocc_lst : *pandas.Series* or *pandas.DataFrame*
96
- Data Frame which contains the information of the requested list
57
+ neocc_lst : `~astropy.table.Table`
58
+ Astropy Table which contains the data of the requested list.
97
59
98
60
Examples
99
61
--------
100
62
**NEA list, Updated NEA list, Monthly computation date:** The output
101
- of this list is a *pandas.Series* which contains the list of all NEAs
63
+ of this list is a `~astropy.table.Table` which contains the list of all NEAs
102
64
currently considered in the NEOCC system.
103
65
104
66
>>> from astroquery.esa.neocc import neocc
@@ -123,7 +85,7 @@ def query_list(list_name):
123
85
>>> list_data[4]
124
86
'1221 Amor'
125
87
126
- **Other lists:** The output of this list is a *pandas.DataFrame* which
88
+ **Other lists:** The output of this list is a `~astropy.table.Table` which
127
89
contains the information of the requested list.
128
90
129
91
>>> from astroquery.esa.neocc import neocc
@@ -195,7 +157,7 @@ def query_list(list_name):
195
157
196
158
return neocc_list
197
159
198
- except ConnectionError : # pragma: no cover
160
+ except ConnectionError : # pragma: no cover
199
161
print ('Initial attempt to obtain list failed. Reattempting...' )
200
162
# Wait 5 seconds
201
163
time .sleep (5 )
@@ -442,12 +404,13 @@ def query_object(name, tab, **kwargs):
442
404
tab_list = ['impacts' , 'close_approaches' , 'observations' ,
443
405
'physical_properties' , 'orbit_properties' ,
444
406
'ephemerides' , 'summary' ]
407
+
445
408
# Check the input of the method if tab is not in the list
446
409
# print and error and show the valid names
447
410
if tab not in tab_list :
448
411
raise KeyError ('Please introduce a valid tab name. '
449
- 'valid tabs names are: ' + \
450
- ', ' .join ([str (elem ) for elem in tab_list ]))
412
+ 'valid tabs names are: '
413
+ ', ' .join ([str (elem ) for elem in tab_list ]))
451
414
# Depending on the tab selected the information will be requested
452
415
# following different methods. Create "switch" for each case:
453
416
@@ -461,32 +424,27 @@ def query_object(name, tab, **kwargs):
461
424
try :
462
425
# Get object data
463
426
data_obj = tabs .get_object_data (url )
464
- except ConnectionError : # pragma: no cover
427
+ except ConnectionError : # pragma: no cover
465
428
print ('Initial attempt to obtain object data failed. '
466
429
'Reattempting...' )
467
430
# Wait 5 seconds
468
431
time .sleep (5 )
469
432
# Get object data
470
433
data_obj = tabs .get_object_data (url )
471
434
435
+ resp_str = data_obj .decode ('utf-8' )
436
+
437
+ # TODO: check data here
438
+
472
439
if tab == 'impacts' :
473
- # Create empty object with class Impacts
474
- neocc_obj = tabs .Impacts ()
475
- # Parse the requested data using Impacts parser
476
- neocc_obj ._impacts_parser (data_obj )
440
+ neocc_obj = tabs .parse_impacts (resp_str )
477
441
elif tab == 'close_approaches' :
478
- # Parse the requested data using Close Approaches parser
479
- neocc_obj = tabs .CloseApproaches .clo_appr_parser (data_obj )
442
+ neocc_obj = tabs .parse_close_aproach (resp_str )
480
443
elif tab == 'observations' :
481
- # Create empty object
482
- neocc_obj = tabs .AsteroidObservations ()
483
- # Get object with attributes from data
484
- neocc_obj ._ast_obs_parser (data_obj )
444
+ neocc_obj = tabs .parse_observations (resp_str )
485
445
elif tab == 'physical_properties' :
486
- # Create empty object with class Physical properties
487
- neocc_obj = tabs .PhysicalProperties ()
488
- # Parse the requested data using Physical properties parser
489
- neocc_obj ._phys_prop_parser (data_obj )
446
+ neocc_obj = tabs .parse_physical_properties (resp_str )
447
+
490
448
# Orbit properties
491
449
elif tab == 'orbit_properties' :
492
450
# Raise error if no elements are provided
@@ -508,25 +466,16 @@ def query_object(name, tab, **kwargs):
508
466
try :
509
467
# Get object data
510
468
data_obj = tabs .get_object_data (url )
511
- except ConnectionError : # pragma: no cover
469
+ except ConnectionError : # pragma: no cover
512
470
print ('Initial attempt to obtain object data failed. '
513
471
'Reattempting...' )
514
472
# Wait 5 seconds
515
473
time .sleep (5 )
516
474
# Get object data
517
475
data_obj = tabs .get_object_data (url )
518
476
519
- # Assign orbit properties depending on the elements requested
520
- if kwargs ['orbital_elements' ] == "keplerian" :
521
- # Create empty object with class Orbit properties
522
- neocc_obj = tabs .KeplerianOrbitProperties ()
523
- # Parse the requested data using Orbit properties parser
524
- neocc_obj ._orb_kep_prop_parser (data_obj )
525
- elif kwargs ['orbital_elements' ] == "equinoctial" :
526
- # Create empty object with class Orbit properties
527
- neocc_obj = tabs .EquinoctialOrbitProperties ()
528
- # Parse the requested data using Orbit properties parser
529
- neocc_obj ._orb_equi_prop_parser (data_obj )
477
+ resp_str = data_obj .decode ('utf-8' )
478
+ neocc_obj = tabs .parse_orbital_properties (resp_str )
530
479
531
480
# Ephemerides
532
481
elif tab == 'ephemerides' :
@@ -539,21 +488,22 @@ def query_object(name, tab, **kwargs):
539
488
# Check if any kwargs is missing
540
489
for element in args_dict :
541
490
if element not in kwargs :
542
- raise KeyError ('Please specify ' + args_dict [element ]
543
- + ' for ephemerides' )
491
+ raise KeyError (f'Please specify { args_dict [element ]} for ephemerides.' )
544
492
545
- # Create empty object with class Ephemerides
546
- neocc_obj = tabs .Ephemerides ()
547
- # Parse the requested data using Ephemerides parser
548
- neocc_obj ._ephem_parser (name , observatory = kwargs ['observatory' ],
493
+ resp_str = tabs .get_ephemerides_data (name , observatory = kwargs ['observatory' ],
549
494
start = kwargs ['start' ], stop = kwargs ['stop' ],
550
495
step = kwargs ['step' ],
551
496
step_unit = kwargs ['step_unit' ])
497
+ neocc_obj = tabs .parse_ephemerides (resp_str )
498
+
552
499
elif tab == 'summary' :
500
+ resp_str = tabs .get_summary_data (name )
501
+
502
+ neocc_obj = tabs .parse_summary (resp_str )
553
503
# Create empty object with class Summary
554
- neocc_obj = tabs .Summary ()
504
+ # neocc_obj = tabs.Summary()
555
505
# Parse the requested data using Summary parser
556
- neocc_obj ._summary_parser (name )
506
+ # neocc_obj._summary_parser(name)
557
507
558
508
return neocc_obj
559
509
0 commit comments