Setting Up Automated Ship Arrival Alerts with Datalastic API

import requests
import time
import json
from datetime import datetime
from geopy.distance import geodesic

target_ports = [
 {"name": "Rotterdam", "coordinates": (51.9225, 4.47917), "unlocode": "NLRTM"},
 {"name": "Singapore", "coordinates": (1.29027, 103.851), "unlocode": "SGSIN"},
 {"name": "Shanghai", "coordinates": (31.2304, 121.4737), "unlocode": "CNSHA"}
]

def is_vessel_at_port(vessel_position, port_coordinates, threshold_km=5):
 """Check if vessel is within threshold distance of port"""
 vessel_coords = (vessel_position['lat'], vessel_position['lon'])
 distance = geodesic(vessel_coords, port_coordinates).kilometers
 return distance <= threshold_km

def monitor_vessels(api_key, vessel_identifiers, check_interval=300):
 """
 Monitor vessels and alert when they reach a target port 
 Parameters:
 - api_key: Your Datalastic API key
 - vessel_identifiers: Dictionary mapping vessel IDs to their type (mmsi, imo, or uuid)
 - check_interval: Time between checks in seconds (default 5 minutes)
 """
 # Track which vessels have already triggered alerts
 alerted_vessels = {} 
 while True:
 for vessel_id, id_type in vessel_identifiers.items():
 try:
 # Call Datalastic Pro Live Ship Tracking API
 response = requests.get(
 f"https://api.datalastic.com/api/v0/vessel_pro",
 params={"api-key": api_key, id_type: vessel_id}
 ) 
 data = response.json() 
 if "data" in data:
 vessel = data["data"]
 vessel_name = vessel.get("name", f"{id_type.upper()}:{vessel_id}")
 position = {"lat": vessel["lat"], "lon": vessel["lon"]} 
 # Get destination information
 destination = vessel.get("destination", "")
 dest_port = vessel.get("dest_port", "")
 dest_unlocode = vessel.get("dest_port_unlocode", "") 
 # Check if vessel is at any monitored port
 for port in target_ports:
 # Check both by coordinates and by destination UNLOCODE
 vessel_port_key = f"{vessel_id}-{port['name']}" 
 at_port_by_location = is_vessel_at_port(position, port["coordinates"])
 at_port_by_unlocode = dest_unlocode == port["unlocode"] and vessel["speed"] < 1 
 if ((at_port_by_location or at_port_by_unlocode) and 
 vessel_port_key not in alerted_vessels):
 # Trigger alert
 send_alert(vessel_name, vessel_id, id_type, port["name"], vessel)
 alerted_vessels[vessel_port_key] = time.time() 
 # Reset alert status if vessel leaves port (optional)
 elif (vessel_port_key in alerted_vessels and 
 not at_port_by_location and 
 vessel["speed"] > 3):  # Ship is moving away
 del alerted_vessels[vessel_port_key] 
 except Exception as e:
 print(f"Error monitoring vessel {id_type}:{vessel_id}: {e}") 
 # Wait before next check
 time.sleep(check_interval)

def send_alert(vessel_name, vessel_id, id_type, port_name, vessel_data):
 """Send an alert when vessel arrives at port"""
 arrival_time = datetime.utcnow().strftime("%Y-%m-%d %H:%M:%S UTC") 
 message = f"""
VESSEL ARRIVAL ALERT
--------------------
Vessel: {vessel_name}
{id_type.upper()}: {vessel_id}
Port: {port_name}
Arrival Time: {arrival_time}
Status: {vessel_data.get('navigational_status', 'Unknown')}
Current Draught: {vessel_data.get('current_draught', 'Unknown')}
Destination: {vessel_data.get('destination', 'Unknown')}
 """ 
 # Print to console
 print(message) 
 # Here you can implement your preferred notification method:
 # send_email(message)
 # send_sms(message)
 # send_slack_notification(message)
 # send_webhook(vessel_data)

import smtplib
from email.message import EmailMessage
def send_email(message_body, recipient="alerts@yourcompany.com"):
 """Send email alert"""
 msg = EmailMessage()
 msg.set_content(message_body) 
 msg['Subject'] = 'Vessel Port Arrival Alert'
 msg['From'] = 'vessel-alerts@yourcompany.com'
 msg['To'] = recipient 
 # Connect to SMTP server and send
 server = smtplib.SMTP('smtp.yourcompany.com', 587)
 server.starttls()
 server.login('username', 'password')
 server.send_message(msg)
 server.quit()

if __name__ == "__main__":
 # Your Datalastic API key
 API_KEY = "your_api_key_here" 
 # List of vessel identifiers to monitor
 # You can use any combination of mmsi, imo, or uuid
 vessels_to_monitor = {
 "566093000": "mmsi",    # MAERSK CHENNAI
 "9525338": "imo",       # MAERSK CHENNAI (alternative identifier)
 "b8625b67-7142-cfd1-7b85-595cebfe4191": "uuid"  # MAERSK CHENNAI (uuid)
 } 
 # Start monitoring (checks every 10 minutes)
 monitor_vessels(API_KEY, vessels_to_monitor, check_interval=600)