У меня есть два процесса:
1) Прослушивание веб-сокета для новых сообщений
2) Отправка новых сообщений на определенный URL-адрес
Я хочу запустить их параллельно.Что я должен использовать?Многопроцессорная обработка, многопоточность или асинхронность?
import requests
import websocket
import time
data = []
def receive_messages(url):
ws = websocket.create_connection(url)
while True:
try:
msg = ws.recv()
except WebSocketConnectionClosedException:
ws = websocket.create_connection(url)
continue
data.append(msg)
def send_messages(url):
while True:
try:
msg = data.pop()
except IndexError:
time.sleep(1)
continue
requests.post(url, payload=msg)