Bienvenue sur le Gitlab destiné aux élèves des sections NSI et ISN 2019 2020 du Lycée Léonard de Vinci à Soissons.

meteo_maj_bd.py 6.84 KB
Newer Older
git's avatar
git committed
1 2 3 4 5
# Créé par thierry, le 22/03/2017 en Python 3.2
from urllib.request import urlopen
import sqlite3
import os
import os.path
git's avatar
git committed
6 7
import time
import datetime
git's avatar
git committed
8

git's avatar
git committed
9 10 11
rep = "/home/thkserver"
#rep = os.getcwd()
#rep = "/home/isn"
git's avatar
git committed
12
try:
git's avatar
git committed
13
    os.mkdir(rep + "/meteo")
git's avatar
git committed
14
except:
git's avatar
git committed
15 16
    print ("/meteo existe deja")
rep=rep+"/meteo"
git's avatar
git committed
17 18 19
os.chdir(rep)
rep_meteo=rep
try:
git's avatar
git committed
20
    os.mkdir(rep + "/Sqlite3")
git's avatar
git committed
21
except:
git's avatar
git committed
22 23 24
    print("/Sqlite3 existe deja")
rep=rep+"/Sqlite3"
fichierBaseDonnees =rep+"/meteo.sq3"
git's avatar
git committed
25 26 27 28 29
con=sqlite3.connect(fichierBaseDonnees)
os.chdir(rep)
try:
    con.execute("CREATE TABLE data (jour INTEGER, mois INTEGER, annee INTEGER, heures INTEGER, minutes INTEGER, temperature_ext REAL, humidite_ext REAL, rosee REAL, pres_rel REAL, vit_vent REAL, raf_vent REAL, dir_vent INTEGER, pluie_min REAL, pluie_heure REAL, pluie_tot REAL)")
except:
git's avatar
git committed
30 31 32 33 34 35 36 37 38 39 40 41 42 43
    print("la table est déjà cree")

def date():
    dateactuelle=[int(time.strftime("%d")),int(time.strftime("%m")),int(time.strftime("%Y")),int(time.strftime("%H")),int(time.strftime("%M"))]
    return(dateactuelle)

def SelectUrlFichierDate(datefichier):
    UrlFichier='http://meteo.ldvsoissons.fr/'+str(datefichier[1])+str(datefichier[2])+'lgcsv.csv'
    print(UrlFichier)
    return(UrlFichier)




git's avatar
git committed
44 45
def enreg():
    fiche=15*[]
git's avatar
git committed
46 47 48
    datefichier=date()
    UrlFichier= SelectUrlFichierDate(datefichier)
    fiche=GestionNouvDonnees(UrlFichier)
git's avatar
git committed
49 50 51 52 53 54 55 56 57 58 59 60 61 62 63
    print(len(fiche))
    dst=filtrer(fiche)
    print("fin filtrage")
    data = open("DonneesActives.csv", "r")
    NouvDonnees=data.readlines()
    for ligne in NouvDonnees:
            # Extraction des données de la ligne séparées par une virgule
            ligne
            donnees = ligne.rstrip('\n').split(",")
            print(donnees)
            con.execute("insert into data (jour, mois, annee, heures, minutes, temperature_ext, humidite_ext, rosee, pres_rel, vit_vent, raf_vent, dir_vent, pluie_min, pluie_heure, pluie_tot) values (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)",donnees)
    con.commit()
    data.close()
    return()

git's avatar
git committed
64 65
def GestionNouvDonnees(UrlFichier):
    url = UrlFichier
git's avatar
git committed
66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108
    with open('meteo.txt', 'wb') as txt:
        txt.write(urlopen(url).read())
    fichier_travail = open('meteo.txt','r')
    NouvDonnees=fichier_travail.readlines()
    fichier_travail.close()
    return(NouvDonnees)

def filtrer(fiche):
    dst = open("DonneesActives.csv", "w")
    Jouridx = 0
    Moisidx = 1
    Anneeidx = 2
    Heureidx = 3
    Minutesidx = 4
    Temperature_extidx = 5
    Humidite_extidx = 6
    Roseeidx = 7
    PressionRelativeidx = 8
    Ventidx = 9
    VentRafaleidx = 10
    DirectionVentidx = 11
    PluieMinuteidx = 12
    PluieHeureidx = 13
    PluieTotalidx = 14
    curseur = con.cursor()
    curseur.execute("SELECT * FROM data ORDER BY annee DESC, mois DESC, jour DESC, heures DESC, minutes DESC LIMIT 1 ")
    last = curseur.fetchone()
    print("last=")
    print(last)
    for ligne in fiche:
        # Extraction des données de la ligne séparées par une virgule
        donnees = ligne.rstrip('\n\r').split(",")
        try:
            if len(last)!=0:
                try:
                        if int(donnees[Anneeidx])>int(last[2]) :
                            dst.write("%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s\n" % (donnees[Jouridx], donnees[Moisidx], donnees[Anneeidx], donnees[Heureidx], donnees[Minutesidx], donnees[Temperature_extidx], donnees[Humidite_extidx], donnees[Roseeidx], donnees[PressionRelativeidx], donnees[Ventidx], donnees[VentRafaleidx], donnees[DirectionVentidx], donnees[PluieMinuteidx], donnees[PluieHeureidx], donnees[PluieTotalidx]))
                        elif int(donnees[Anneeidx])==int(last[2]) and int(donnees[Moisidx])>int(last[1]):
                            dst.write("%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s\n" % (donnees[Jouridx], donnees[Moisidx], donnees[Anneeidx], donnees[Heureidx], donnees[Minutesidx], donnees[Temperature_extidx], donnees[Humidite_extidx], donnees[Roseeidx], donnees[PressionRelativeidx], donnees[Ventidx], donnees[VentRafaleidx], donnees[DirectionVentidx], donnees[PluieMinuteidx], donnees[PluieHeureidx], donnees[PluieTotalidx]))
                        elif int(donnees[Anneeidx])==int(last[2]) and int(donnees[Moisidx])==int(last[1]) and int(donnees[Jouridx])>int(last[0]):
                            dst.write("%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s\n" % (donnees[Jouridx], donnees[Moisidx], donnees[Anneeidx], donnees[Heureidx], donnees[Minutesidx], donnees[Temperature_extidx], donnees[Humidite_extidx], donnees[Roseeidx], donnees[PressionRelativeidx], donnees[Ventidx], donnees[VentRafaleidx], donnees[DirectionVentidx], donnees[PluieMinuteidx], donnees[PluieHeureidx], donnees[PluieTotalidx]))
                        elif int(donnees[Anneeidx])==int(last[2]) and int(donnees[Moisidx])==int(last[1]) and int(donnees[Jouridx])==int(last[0]) and int(donnees[Heureidx])>int(last[3]):
                            dst.write("%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s\n" % (donnees[Jouridx], donnees[Moisidx], donnees[Anneeidx], donnees[Heureidx], donnees[Minutesidx], donnees[Temperature_extidx], donnees[Humidite_extidx], donnees[Roseeidx], donnees[PressionRelativeidx], donnees[Ventidx], donnees[VentRafaleidx], donnees[DirectionVentidx], donnees[PluieMinuteidx], donnees[PluieHeureidx], donnees[PluieTotalidx]))
git's avatar
git committed
109
                        elif int(donnees[Anneeidx])==int(last[2]) and int(donnees[Moisidx])==int(last[1]) and int(donnees[Jouridx])==int(last[0]) and int(donnees[Heureidx])==int(last[3]) and int(donnees[Minutesidx])>int(last[4]):
git's avatar
git committed
110 111 112 113 114 115 116 117 118 119 120 121 122
                            dst.write("%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s\n" % (donnees[Jouridx], donnees[Moisidx], donnees[Anneeidx], donnees[Heureidx], donnees[Minutesidx], donnees[Temperature_extidx], donnees[Humidite_extidx], donnees[Roseeidx], donnees[PressionRelativeidx], donnees[Ventidx], donnees[VentRafaleidx], donnees[DirectionVentidx], donnees[PluieMinuteidx], donnees[PluieHeureidx], donnees[PluieTotalidx]))

                except:
                    print("les nouveaux enregistrements sont sélectionnés")

            else:
                dst.write("%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s\n" % (donnees[Jouridx], donnees[Moisidx], donnees[Anneeidx], donnees[Heureidx], donnees[Minutesidx], donnees[Temperature_extidx], donnees[Humidite_extidx], donnees[Roseeidx], donnees[PressionRelativeidx], donnees[Ventidx], donnees[VentRafaleidx], donnees[DirectionVentidx], donnees[PluieMinuteidx], donnees[PluieHeureidx], donnees[PluieTotalidx]))
        except:
                dst.write("%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s,%s\n" % (donnees[Jouridx], donnees[Moisidx], donnees[Anneeidx], donnees[Heureidx], donnees[Minutesidx], donnees[Temperature_extidx], donnees[Humidite_extidx], donnees[Roseeidx], donnees[PressionRelativeidx], donnees[Ventidx], donnees[VentRafaleidx], donnees[DirectionVentidx], donnees[PluieMinuteidx], donnees[PluieHeureidx], donnees[PluieTotalidx]))
    dst.close()
    return(dst)

enreg()