bsc/maregraphe
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Compare commits

base: b.soussi-chiadmi:ddc7446d8c4df1d9164bc5ebdf7d4c8f96660457
Branches Tags
b.soussi-chiadmi:main
..
compare: b.soussi-chiadmi:cf4e506523a5756dc603a163da894eb79ef374b4
Branches Tags
b.soussi-chiadmi:main

No commits in common. "ddc7446d8c4df1d9164bc5ebdf7d4c8f96660457" and "cf4e506523a5756dc603a163da894eb79ef374b4" have entirely different histories.
ddc7446d8c ... cf4e506523

2 changed files with 16 additions and 187 deletions
Show Stats Expand all files Collapse all files

166
chom.json
View File

@ -1,166 +0,0 @@
{
"shom_id": "386",
"name": "BALISE_A",
"longitude": 0.110667,
"latitude": 49.431833,
"state": "OK",
"reseau": "REFMAR",
"alertCustom": false,
"delai_alerte": "06:00",
"members": [
{
"individual_name": "HAROPA PORT | Rouen",
"organization_name": "HAROPA PORT | Rouen",
"voice": "",
"delivery_point": "",
"city": "",
"postal_code": "",
"electronic_mail_address": "scan@rouen.port.fr"
}
],
"events": [
{
"id": "1855",
"tide_gauge_id": "386",
"content": "P\u00e9riode d'\u00e9chantillonnage = 1 seconde\nDur\u00e9e d'int\u00e9gration = 61 secondes\nP\u00e9riode d'archivage = 5 minutes\n\nLa p\u00e9riode d'archivage n'est pas centr\u00e9e sur la dur\u00e9e d'int\u00e9gration mais uniquement sur la derni\u00e8re observation.",
"creation_date": "2023-08-30T12:21:06.000Z",
"due_date": "2015-01-01T01:00:00.000Z"
}
],
"organismes": [
{
"nom": "HAROPA PORT | Rouen",
"logo": "https://services.data.shom.fr/static/logo/DDM/logo_GPM_le_havre.png",
"url": "https://www.haropaport.com/fr"
}
],
"verticalRef": {
"nom_ref": "IGN69",
"zero_hydro": "zero_hydrographique",
"zh_ref": "-4.38"
},
"date_prem_obs": "1985-03-31",
"fuseau_horaire": "0",
"gestionnaire": "Grand Port Maritime Rouen",
"id_ram": "PK 364,775 : Balise A",
"info_maregraphe": "https://refmar.shom.fr/donnees/386",
"journal_de_bord": "https://refmar.shom.fr/donnees/386",
"niveau_moyen": "4.91",
"npbma": "0.21",
"nphma": "8.64",
"sect_geographique": "FH",
"spm": "BALISE_A",
"ville_d_hebergement": "Le Havre"
}
2025-04-24 16:11:23,976 - INFO - Hauteur de la marée : -4.38 mètres
print: -4.38
2025-04-24 16:11:34,227 - INFO - {
"shom_id": "386",
"name": "BALISE_A",
"longitude": 0.110667,
"latitude": 49.431833,
"state": "OK",
"reseau": "REFMAR",
"alertCustom": false,
"delai_alerte": "06:00",
"members": [
{
"individual_name": "HAROPA PORT | Rouen",
"organization_name": "HAROPA PORT | Rouen",
"voice": "",
"delivery_point": "",
"city": "",
"postal_code": "",
"electronic_mail_address": "scan@rouen.port.fr"
}
],
"events": [
{
"id": "1855",
"tide_gauge_id": "386",
"content": "P\u00e9riode d'\u00e9chantillonnage = 1 seconde\nDur\u00e9e d'int\u00e9gration = 61 secondes\nP\u00e9riode d'archivage = 5 minutes\n\nLa p\u00e9riode d'archivage n'est pas centr\u00e9e sur la dur\u00e9e d'int\u00e9gration mais uniquement sur la derni\u00e8re observation.",
"creation_date": "2023-08-30T12:21:06.000Z",
"due_date": "2015-01-01T01:00:00.000Z"
}
],
"organismes": [
{
"nom": "HAROPA PORT | Rouen",
"logo": "https://services.data.shom.fr/static/logo/DDM/logo_GPM_le_havre.png",
"url": "https://www.haropaport.com/fr"
}
],
"verticalRef": {
"nom_ref": "IGN69",
"zero_hydro": "zero_hydrographique",
"zh_ref": "-4.38"
},
"date_prem_obs": "1985-03-31",
"fuseau_horaire": "0",
"gestionnaire": "Grand Port Maritime Rouen",
"id_ram": "PK 364,775 : Balise A",
"info_maregraphe": "https://refmar.shom.fr/donnees/386",
"journal_de_bord": "https://refmar.shom.fr/donnees/386",
"niveau_moyen": "4.91",
"npbma": "0.21",
"nphma": "8.64",
"sect_geographique": "FH",
"spm": "BALISE_A",
"ville_d_hebergement": "Le Havre"
}
2025-04-24 16:11:34,227 - INFO - Hauteur de la marée : -4.38 mètres
print: -4.38
2025-04-24 16:11:44,339 - INFO - {
"shom_id": "386",
"name": "BALISE_A",
"longitude": 0.110667,
"latitude": 49.431833,
"state": "OK",
"reseau": "REFMAR",
"alertCustom": false,
"delai_alerte": "06:00",
"members": [
{
"individual_name": "HAROPA PORT | Rouen",
"organization_name": "HAROPA PORT | Rouen",
"voice": "",
"delivery_point": "",
"city": "",
"postal_code": "",
"electronic_mail_address": "scan@rouen.port.fr"
}
],
"events": [
{
"id": "1855",
"tide_gauge_id": "386",
"content": "P\u00e9riode d'\u00e9chantillonnage = 1 seconde\nDur\u00e9e d'int\u00e9gration = 61 secondes\nP\u00e9riode d'archivage = 5 minutes\n\nLa p\u00e9riode d'archivage n'est pas centr\u00e9e sur la dur\u00e9e d'int\u00e9gration mais uniquement sur la derni\u00e8re observation.",
"creation_date": "2023-08-30T12:21:06.000Z",
"due_date": "2015-01-01T01:00:00.000Z"
}
],
"organismes": [
{
"nom": "HAROPA PORT | Rouen",
"logo": "https://services.data.shom.fr/static/logo/DDM/logo_GPM_le_havre.png",
"url": "https://www.haropaport.com/fr"
}
],
"verticalRef": {
"nom_ref": "IGN69",
"zero_hydro": "zero_hydrographique",
"zh_ref": "-4.38"
},
"date_prem_obs": "1985-03-31",
"fuseau_horaire": "0",
"gestionnaire": "Grand Port Maritime Rouen",
"id_ram": "PK 364,775 : Balise A",
"info_maregraphe": "https://refmar.shom.fr/donnees/386",
"journal_de_bord": "https://refmar.shom.fr/donnees/386",
"niveau_moyen": "4.91",
"npbma": "0.21",
"nphma": "8.64",
"sect_geographique": "FH",
"spm": "BALISE_A",
"ville_d_hebergement": "Le Havre"
}

35
main.py
View File

@ -8,13 +8,9 @@ import json
import subprocess import subprocess
# Configuration de l'API REFMAR # Configuration de l'API REFMAR
# API_URL = "https://services.data.shom.fr/maregraphie/service/completetidegauge" API_URL = "https://services.data.shom.fr/maregraphie/service/completetidegauge"
# API_URL = "https://services.data.shom.fr/maregraphie/observation/json"
# curl -X GET "https://services.data.shom.fr/maregraphie/observation/json/386?sources=1&dtStart=2025-05-22T15%3A56%3A00Z&dtEnd=2025-05-22T15%3A57%3A00Z&interval=1" -H "accept: application/json"
# API_KEY = "votre_cle_api" # Remplacez par votre clé API # API_KEY = "votre_cle_api" # Remplacez par votre clé API
# STATION = '386' # Identifiant de la station du Havre STATION = '386' # Identifiant de la station du Havre
API_URL = "https://data.haropaport.com/sig/capteur/hauteur"
UDP_IP = "127.0.0.1" UDP_IP = "127.0.0.1"
UDP_PORT = 8765 UDP_PORT = 8765
@ -30,13 +26,11 @@ def fetch_data():
# "Ocp-Apim-Subscription-Key": API_KEY, # "Ocp-Apim-Subscription-Key": API_KEY,
} }
params = { params = {
# "sources": 1, # "station": STATION,
# "dtStart": "2025-05-22T10:00:00Z", # "time": "current", # Vous pouvez ajuster ce paramètre selon vos besoins
# "dtEnd": "2025-05-22T17:00:00Z",
# # "interval": 1
} }
try: try:
response = requests.get(API_URL, headers=headers, params=params) response = requests.get(API_URL+"/"+STATION, headers=headers, params=params)
response.raise_for_status() response.raise_for_status()
return response.json() return response.json()
except requests.RequestException as e: except requests.RequestException as e:
@ -46,11 +40,12 @@ def fetch_data():
def process_data(data): def process_data(data):
"""Traite les données récupérées.""" """Traite les données récupérées."""
try: try:
for item in data['items']: zh_ref = data.get("verticalRef", {}).get("zh_ref", 0)
if item['id'] == "hauteur_shom": logging.info(f"Hauteur de la marée : {zh_ref} mètres")
logging.info(f"{item["capteur"]} Hauteur d'eau : {item["valeur"]} mètres") zh_ref_bytes = f"{zh_ref};".encode('utf-8')
hauteurdeau_bytes = f"{item["valeur"]};".encode('utf-8') sock.sendto(zh_ref_bytes, (UDP_IP, UDP_PORT))
sock.sendto(hauteurdeau_bytes, (UDP_IP, UDP_PORT)) # sock.sendto(float(zh_ref).to_bytes(8, byteorder='big'), (UDP_IP, UDP_PORT))
# sock.sendto(float(zh_ref), (UDP_IP, UDP_PORT))
except Exception as e: except Exception as e:
logging.error(f"Erreur lors du traitement des données : {e}") logging.error(f"Erreur lors du traitement des données : {e}")
@ -59,14 +54,13 @@ def main():
logging.info("Démarrage de l'application de traitement des données du marégraphe.") logging.info("Démarrage de l'application de traitement des données du marégraphe.")
# lancement du patch pd # lancement du patch pd
pd_patch = "./maregraphe.pd" # Remplace par le chemin de ton patch pd_patch = "./maregraphe.pd" # Remplace par le chemin de ton patch
# pd_process = subprocess.Popen(["pd", "-nogui", "-open", pd_patch]) pd_process = subprocess.Popen(["pd", "-nogui", "-open", pd_patch])
pd_process = subprocess.Popen(["pd", "-open", pd_patch])
try: try:
while True: while True:
print('/ / / / / / / / / / / / / / / / / / / / / / / / / / / / / /')
data = fetch_data() data = fetch_data()
# logging.info(json.dumps(data, indent=2)) logging.info(json.dumps(data, indent=2))
# print(data)
if data: if data:
process_data(data) process_data(data)
time.sleep(10) # 300 Attendre 5 minutes time.sleep(10) # 300 Attendre 5 minutes
@ -75,5 +69,6 @@ def main():
pd_process.terminate() pd_process.terminate()
if __name__ == "__main__": if __name__ == "__main__":
main() main()