Python обрабатывать данные в нескольких очередях - PullRequest
Новая
       7

Python обрабатывать данные в нескольких очередях

0 голосов
/ 07 марта 2019

У меня есть следующие данные: 

[
    {"name": "item1", "type": "branded"},
    {"name": "item2", "type": "generic"},
    {"name": "item3", "type": "otc"}
]

Каждый тип входит в свою очередь.Максимальный лимит в очереди - 5 (максимальное количество принятых наркотиков).если есть переполнение, то оно должно храниться в очереди без обработки.Необработанная очередь также имеет максимальный предел 10. Все, что больше 10, должно быть настроено на возвратную очередь, которую следует отправлять поставщику.Я пытаюсь обработать это, используя очередь Python, но почему-то потерял способ определить это.

вот как будут выглядеть окончательные данные. 

data = ['item1', 'item2', 'item3', 'item4', 'item5', 'item6', 'item7', 'item8', 'item9', 'item10', 'item11', 'item12', 'item13', 'item14', 'item15', 'item16', 'item17', 'item18', 'item19']

branded_q = [item1, item4, item7, item10, item13]
generic_q = [item2, item5, item8, item11, item14]
otc_q = [item3, item6, item9, item12, item15]
non_processed_q = [item16, item17, item18, item19]
return_q = []

будет return_qбыть отправлены обратно продавцу.Обратите внимание, что данные будут использованы через событие kafka в режиме реального времени.

...