Очередь Python не обновляется за пределами потокаPython

Программы на Python
Ответить
Anonymous
 Очередь Python не обновляется за пределами потока

Сообщение Anonymous »

Я создал приложение Flask, которое извлекает данные из очереди, которая обновляется в отдельном потоке. Я не уверен, почему очередь пуста, когда я получаю ее из конечной точки Flask GET, и немного не знаю, что означает поточно-безопасность очередей, поскольку мой пример, похоже, не отражает этого.
В приведенном ниже примере очередь в маршруте измерений Flask @app.route('/measurements') пуста, даже если она обновлена ​​в обработчике сообщений TCP. Если кто-нибудь может меня просветить, я был бы признателен.
Я запускаю это на Ubuntu с Python3, если это актуально.
from flask import Flask, render_template
import socket
from threading import Thread
import os
from wyze_sdk import Client
from dotenv import load_dotenv
from wyze_sdk.errors import WyzeApiError
import time
from queue import Queue

load_dotenv()

app = Flask(__name__)

start_time = time.time()

response = Client().login(
email=os.environ['WYZE_EMAIL'],
password=os.environ['WYZE_PASSWORD'],
key_id=os.environ['WYZE_KEY_ID'],
api_key=os.environ['WYZE_API_KEY']
)

client = Client(token=response['access_token'])

HOST = '192.168.1.207' # Listen on all network interfaces
PORT = 9000 # The same port as in your ESP8266 sketch

PORT_UI = 7001

MIN_WATER_DIST = 20 # minimum distance from sensor to water in cm
MAX_WATER_DIST = 45 # maximum distance from sensor to water in cm
MAX_TIME_PLUG_ON = 600 # maximum amount of time plug should be on

# Initialize state variables
plug_on_time = None # Track when the plug was turned on

measurements = Queue(maxsize=86400)

@app.route('/measurements')
def measurements_api():
current_time = time.time()
recent_measurements = [m for m in list(measurements.queue) if current_time - m['timestamp']

Подробнее здесь: https://stackoverflow.com/questions/793 ... -of-thread
Ответить

Быстрый ответ

Изменение регистра текста: 
Смайлики
:) :( :oops: :roll: :wink: :muza: :clever: :sorry: :angel: :read: *x)
Ещё смайлики…
   
К этому ответу прикреплено по крайней мере одно вложение.

Если вы не хотите добавлять вложения, оставьте поля пустыми.

Максимально разрешённый размер вложения: 15 МБ.

Вернуться в «Python»