wa_gc_api / google_db.py
DmitrMakeev's picture
Update google_db.py
45453fb verified
raw
history blame
1.69 kB
from flask import request, jsonify
import globs
import os
import asyncio
import aiohttp
api_variabl = os.getenv('api_key')
google_url = os.getenv('goo_url')
async def async_save_db(data):
async with aiohttp.ClientSession() as session:
async with session.post(google_url, data=data, headers={'Content-Type': 'application/x-www-form-urlencoded'}) as response:
# Просто проверяем статус код, не ожидая тела ответа
if response.status == 200:
return True
else:
return False
def save_db():
err = 0
if api_variabl == request.args.get('api'):
dey_db = globs.dey
wek_db = globs.wek
v_hid_db = globs.v_hid
v_min_db = globs.v_min
ph_db = globs.ph
ec_db = globs.ec
tS_db = globs.tS
tA_db = globs.tA
hDm_db = globs.hDm
sVen_db = globs.sVen
ec_A_eep_db = globs.ec_A_eep
ec_B_eep_db = globs.ec_B_eep
ec_C_eep_db = globs.ec_C_eep
data = f"action=addData&dey={dey_db}&wek={wek_db}&v_hid={v_hid_db}&v_min={v_min_db}&ph={ph_db}&ec={ec_db}&tS={tS_db}&tA={tA_db}&hDm={hDm_db}&sVen={sVen_db}&ec_A_eep={ec_A_eep_db}&ec_B_eep={ec_B_eep_db}&ec_C_eep={ec_C_eep_db}"
# Отправляем корутину в существующий цикл событий
asyncio.run_coroutine_threadsafe(async_save_db(data), app.loop)
response_data = {
"eep_set": globs.eep_set,
"err": err
}
return jsonify(response_data)
@app.route("/save_db", methods=['GET'])
def handle_save_db():
response = save_db()
return response