Написать асинхронную обработку сообщений на python3.6

Прикладное ПОЗакрытнет заявок117 просмотров
Найдите исполнителя для вашего проекта прямо сейчас!
Разместите заказ на фриланс-бирже и предложения поступят уже через несколько минут.

Внимание, если нет опыта с pyZMQ и AsyncIO лучше не терять время ) 

Есть код: 

import zmq 

import datetime 

################################################## ################################################## ## 

port_01 = "5559" 

port_02 = "5579" 

################################################## ################################################## ## 

context_01 = zmq.Context() 

context_02 = zmq.Context() 

socket_01 = context_01.socket(zmq.PAIR) 

socket_02 = context_02.socket(zmq.PAIR) 

socket_01.bind("tcp://*:%s" % port_01) 

socket_02.bind("tcp://*:%s" % port_02) 

while True: 

    try: 

        start_time = datetime.datetime.now() 

        data_0 = json.loads(socket_01.recv()) 

        data_2 = json.loads(socket_02.recv()) 

        print(data_0) 

        print(data_2) 

Проблема в том что вызов socket_02.recv() блокирующий, соответственно пока не придут данные data_0 не принимаются данные data_2  

Скорость отправки сообщений разная, поэтому программа работает некорректно 

Нужно написать три функции: два не блокирующих получения данных, и третья, которая эти данные обрабатывает.  

Вот тема с похожим обсуждением – https://stackoverflow.com/questions/27183148/why-asyncio-queue-could-not-work-as-expected

https://pyzmq.readthedocs.io/en/latest/api/zmq.asyncio.html

В итоге должны независимо друг от друга непрерывно литься данные в две функции, а третья их параллельно обрабатывать

Python
6 лет назад
Saulyak2
Василий 
33 годаУкраина
6 лет в сервисе
Был
5 лет назад
24 отзыва
  • Похожие заказы

  • Требуется декомпилировать сложное ПО на C++/Delphi

    Требуется декомпилировать ПО на C++/Delphi. Существует большой программный комплекс под Windows, написанный скорее всего на C++/Delphi. Требуется его декомпилировать, немного переработав, но оставив исходный функционал.

    Delphi
    Прикладное ПО3 заявки
    Закрыт
    6 лет назад

  • Написать рекламную программу

    Необходимо написать программу рекламно информационного характера которая помещает необходимую иконку в панель задач по аналогии с HP Support Assistant и ярлык на рабочий стол. 1. Программа должна ставится в тихом режиме без дополнительных окон. 2. Должна быть ...

    Прикладное ПО3 заявки
    Закрыт
    6 лет назад

  • Генерация ценника в PDF (svg/png...) на C# .Net 4.5

    Всем привет!  Не спешно требуется (в течении месяца-двух) написать компонент по генерации ценника в заданном дизайне. После генерации это пойдёт в печать, размер половинка вертикальная А4. Не спешим, поэтому задача отлично подойдёт джуниуру для освоения технологии ...

    ASP.NET
    Прикладное ПО3 заявки
    Закрыт
    6 лет назад

  • Написать Backend приложение

    Доброго дня. Я создаю стартап, сети цифровых контактов. [url=https://youtu.be/tbX73xlkWC0]https://youtu.be/tbX73xlkWC0[/url] [url=http://flybc.net/]http://flybc.net[/url] Нужно написать приложение которое, будет создавать электронные визитки и закреплять их за координатами. Используя в качестве источника Google places и Яндекс аналог. Особености: [list][*]Возможность запуска на локацию. Например запроцесить только один ...

    Node.js
    Прикладное ПО1 заявка
    Закрыт
    6 лет назад

  • Создать параметрическую 3D-модель гнутой проволоки

    Работа срочная. Мы ищем программиста, который может создать скрипт, генерирующий 3D-модель гнутой проволоки (задан диаметр проволоки и массив – углы сгибов и расстояния между сгибами). Эта модель затем будет отображаться в браузере в WebGL-рендере.  Укажите примерные ...

    3D-модельWebGL
    Прикладное ПО1 заявка
    Закрыт
    6 лет назад

  • Необходимо разобраться и настроить работу парсера

    "Имеется программа-парсер, в виде Windows Приложения, работает в связке с PHP скриптами, установленными на Wordpress сайте. Gлатформа win32 да, или виндоуз, точно не ЛИНУКС. Эта связка не работает корректно или работает со сбоями. Алгоритм работы ...

    PHPWordPress
    Прикладное ПО3 заявки
    Закрыт
    6 лет назад

  • Разработка блокчейн проекта на C++ (QT)

    Необходим разработчик форка криптовалюты Dash (Pivx) для написания на их основе нового блокчейна, его запуска и сопровождения. Оплата в монетах нового проекта, по факту вы включаетесь в команду разработчиков на правах Chief Developer. Примерно, если ...

    LinuxBlockchain
    Прикладное ПО1 заявка
    Закрыт
    6 лет назад