voir<\/a><\/p>\n\n\n\nPlusieurs petits probl\u00e8mes au chargement des donn\u00e9es dans le syst\u00e8me d\u00fb \u00e0 la valeur de TIMESTAMP et \u00e0 l’insertion des \u00e9l\u00e9ments. Pour cela il est n\u00e9cessaire de convertir les valeurs avant insertion.<\/p>\n\n\n\n
# -----------------------------------------------------------------\n# Y. Stroppa SPGoO\/OSUC\n# 04\/02\/2026\n# Script d\u00e9velopp\u00e9 pour permettre l'importation des donn\u00e9es du SNO dans Influxdb\n# -----------------------------------------------------------------\nfrom influxdb_client import WritePrecision, InfluxDBClient, Point\nfrom influxdb_client.client.write_api import SYNCHRONOUS\nimport pandas as pd\nimport time\nfrom datetime import datetime \nimport csv\n\n# param\u00e8tres de la connexion avec la serveur influxdb\nurl = 'http:\/\/192.168.150.168:8181'\ntoken = 'TOKEN A RECUPERER SUR LE SERVEUR'\norg = 'my-org'\nbucket = 'my-sno'\n\n# Chargement des donn\u00e9es \u00e0 partir du fichier externe CSV \nf=open('ICOSETC_FR-LGt_METEO_L2.csv', newline='')\nreader = csv.reader(f,delimiter=',', quotechar='|') \nheaders = next(reader, None) \n\ndef is_float(element:any)->bool:\n if element is None:\n return False\n try:\n float(element)\n return True\n except ValueError:\n return False\n\nclient=InfluxDBClient(url=url, token=token, org=org)\nwrite_api=client.write_api(write_options=SYNCHRONOUS) \n\nfor row in reader:\n p = Point(\"sonde\")\n for h, v in zip(headers, row):\n if h==\"TIMESTAMP_START\": # or h==\"TIMESTAMP_END\":\n v+=\"00\"\n v=time.mktime(datetime.strptime(v,\"%Y%m%d%H%M%S\").timetuple())\n print(type(v))\n p.time(datetime.fromtimestamp(v),WritePrecision.MS)\n elif h==\"TIMESTAMP_END\":\n v=time.mktime(datetime.strptime(v,\"%Y%m%d%H%M\").timetuple())\n p.field(h,v)\n else:\n p.tag(\"location\", \"La Guette\")\n value=v\n if is_float(v):\n value=float(v)\n p.field(h,value)\n # Ecriture de l'\u00e9l\u00e9ment dans la base\n write_api.write(bucket=bucket, record=p) \n\n\n<\/code><\/pre>\n","protected":false},"excerpt":{"rendered":"POC : InfluxDB Objectifs du POC : mettre en place la solution initiale du site SNO avec sa base de donn\u00e9es Postgresql et une solution avec la base de donn\u00e9es InfluxDB. Pouvoir d\u00e9finir un jeu de requ\u00eates et de traitements pour les deux solutions. Les aspects de performances et de consommation de ressources seront prises […]<\/p>\n","protected":false},"author":1,"featured_media":0,"parent":0,"menu_order":0,"comment_status":"closed","ping_status":"closed","template":"","meta":{"footnotes":""},"class_list":["post-11715","page","type-page","status-publish","hentry"],"_links":{"self":[{"href":"https:\/\/spgoo.org\/index.php?rest_route=\/wp\/v2\/pages\/11715","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/spgoo.org\/index.php?rest_route=\/wp\/v2\/pages"}],"about":[{"href":"https:\/\/spgoo.org\/index.php?rest_route=\/wp\/v2\/types\/page"}],"author":[{"embeddable":true,"href":"https:\/\/spgoo.org\/index.php?rest_route=\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/spgoo.org\/index.php?rest_route=%2Fwp%2Fv2%2Fcomments&post=11715"}],"version-history":[{"count":27,"href":"https:\/\/spgoo.org\/index.php?rest_route=\/wp\/v2\/pages\/11715\/revisions"}],"predecessor-version":[{"id":11760,"href":"https:\/\/spgoo.org\/index.php?rest_route=\/wp\/v2\/pages\/11715\/revisions\/11760"}],"wp:attachment":[{"href":"https:\/\/spgoo.org\/index.php?rest_route=%2Fwp%2Fv2%2Fmedia&parent=11715"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}
![\"\"](\"https:\/\/spgoo.org\/wp-content\/uploads\/2026\/02\/Capture-decran-du-2026-02-03-17-35-42-1024x478.png\")
<\/figure>\n<\/div>\n\n\n![\"\"](\"https:\/\/spgoo.org\/wp-content\/uploads\/2026\/02\/Capture-decran-du-2026-02-03-17-39-08-1024x285.png\")
<\/figure>\n<\/div>\n\n\n