-
Notifications
You must be signed in to change notification settings - Fork 9
/
1_china.py
38 lines (29 loc) · 1.62 KB
/
1_china.py
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
"""
Let's retrieve all the VLCCs that have discharged into China in the last 3 months.
The below script returns:
| | events.cargo_port_unload_event.0.start_timestamp | product.group.label | product.grade.label | quantity | vessels.0.name |
|---:|:---------------------------------------------------|:----------------------|:----------------------|-----------:|:-----------------|
| 0 | 2019-10-08T00:41:00+0000 | Crude | Djeno | 123457 | AROME |
| 1 | 2019-11-08T00:41:52+0000 | Crude | Arab Medium | 99898 | SCOOBYDOO |
| 2 | 2019-09-30T23:49:41+0000 | Crude | Arab Heavy | 9879878 | DAVID |
| 3 | 2019-12-01T01:40:00+0000 | Crude | Usan | 999999 | DUCK |
"""
from datetime import datetime
from vortexasdk import CargoMovements, Geographies, Vessels
if __name__ == "__main__":
# Find china ID
china = Geographies().search(term="China", exact_term_match=True).to_list()[0].id
# Find the ID of all VLCCs
vlccs = [
v.id for v in Vessels().search(vessel_classes="vlcc_plus").to_list()
]
# Query API
search_result = CargoMovements().search(
filter_activity="loading_start",
filter_vessels=vlccs,
filter_destinations=china,
filter_time_min=datetime(2019, 9, 29),
filter_time_max=datetime(2019, 10, 30),
)
# Convert search result to dataframe
df = search_result.to_df()