| 12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364 |
- import requests
- import csv
- import os
- os.makedirs('data', exist_ok=True)
- url_token = 'https://ems.zhpowering.com/public/user/login'
- headers_token = {
- 'Content-Type': 'application/json'
- }
- account = {
- 'account': 'wanggao',
- 'pwd': 'e10adc3949ba59abbe56e057f20f883e'
- }
- response = requests.post(url_token, json=account, headers=headers_token)
- print(response.text)
- response_token=response.json()
- token = response_token['data']['token']
- print("Get Token Successfully:", token)
- headers_data = {
- 'Authorization': token
- }
- project_id='6d2012e5f3a4436499d9e2a9fb15596e'
- device_id='1407'
- key_target='com_ap'
- start_time='2024-01-24 00:00:00'
- end_time='2024-01-24 23:59:59'
- url = 'https://ems.zhpowering.com/api/seqData/fieldValues?projId=%s&deviceId=%s&key=%s&startTime=%s&endTime=%s'%(project_id,device_id,key_target,start_time,end_time)
- response = requests.get(url, headers=headers_data)
- if response.status_code == 200:
- data = response.json()
-
- for entry in data['data']:
- date = entry['date']
- fold_path_data='data/%s_%s'%(key_target,device_id)
- os.makedirs(fold_path_data, exist_ok=True)
- csv_file_path = f'data/%s_%s/{date}.csv'%(key_target,device_id)
- rows = []
- for value_entry in entry['values']:
- time = value_entry['time']
- value = value_entry['value']
- rows.append([time, value])
- with open(csv_file_path, 'w', newline='', encoding='utf-8') as csvfile:
- csv_writer = csv.writer(csvfile)
- csv_writer.writerow(['Time', 'Value'])
- csv_writer.writerows(rows)
- print(f"Data for date {date} written to {csv_file_path}")
- else:
- print(f"Error: {response.status_code}")
|
