73 lines
2.5 KiB
Python
73 lines
2.5 KiB
Python
import os
|
|
import requests
|
|
import shutil
|
|
import json
|
|
|
|
class Send_data_stocked:
|
|
def __init__(self):
|
|
self.url = "https://timelapse.kerboul.me/api/camera/upload"
|
|
self.headers = {
|
|
'accept': 'application/json'
|
|
}
|
|
self.project_path = "//home//timelapse//Documents//Time_Lapse//PROJECT//"
|
|
|
|
def get_list_folder(self,path = "//home//timelapse//Documents//Time_Lapse//PROJECT"):
|
|
# Liste des noms de dossiers
|
|
noms_dossiers = [nom for nom in os.listdir(path) if os.path.isdir(os.path.join(path, nom))]
|
|
print("Noms des dossiers :", noms_dossiers)
|
|
return noms_dossiers
|
|
|
|
def send_ALL_data_stocked(self):
|
|
tab_files = self.get_list_folder()
|
|
for i in tab_files:
|
|
self.send_data_stocked(i)
|
|
|
|
def send_data_stocked(self,file_name):
|
|
file_path = self.project_path + file_name + "//" + file_name
|
|
json_file_path = file_path + ".json"
|
|
img_file_path = file_path + ".jpg"
|
|
|
|
datas = self.get_json(json_file_path)
|
|
print(datas)
|
|
answer_from_server = self.upload_measurement(img_file_path, datas["timestamp"], datas["temperature"], datas["humidity"])
|
|
print(answer_from_server)
|
|
if (answer_from_server["message"]== "Mesure téléchargée avec succès"):
|
|
self.del_Folder(datas["timestamp"])
|
|
|
|
def get_json(self, file_path):
|
|
with open(file_path, "r", encoding='utf-8') as file:
|
|
datas = json.load(file)
|
|
return datas
|
|
return False
|
|
|
|
def del_Folder(self, name):
|
|
shutil.rmtree(self.project_path + name)
|
|
|
|
def upload_measurement(self, image_path, timestamp, temperature, humidity):
|
|
|
|
data = {
|
|
'timestamp': timestamp,
|
|
'temperature': temperature,
|
|
'humidity': humidity
|
|
}
|
|
files = {
|
|
'image': (image_path, open(image_path, 'rb'), 'image/jpeg')
|
|
}
|
|
try:
|
|
#print(data)
|
|
#print(files)
|
|
response = requests.post(self.url, headers=self.headers, data=data, files=files)
|
|
print(response)
|
|
response.raise_for_status()
|
|
response_data = response.json()
|
|
return response_data
|
|
except requests.exceptions.HTTPError as http_err:
|
|
print(f"HTTP error occurred: {http_err}")
|
|
except Exception as err:
|
|
print(f"Other error occurred: {err}")
|
|
|
|
if __name__ == "__main__":
|
|
SDS = Send_data_stocked()
|
|
#a = SDS.get_list_folder()[0]
|
|
SDS.send_ALL_data_stocked()
|