Как передать массив словаря в приложение Faust? - PullRequest
Новая
       23

Как передать массив словаря в приложение Faust?

0 голосов
/ 24 февраля 2019
  1. Как передать массив словарей в приложение Faust?
  2. Как мы можем получить временную метку созданного события?

Я пробую Faust, но вроде как потерял способ чтения потока данных, который находится в массивесловарей.

Пример: 

[{"product_id": "p1", "name": "pen"}, {"product_id": "p2", "name": "eraser"}]

class Products(faust.Record, coercions={UUID: UUID}):
    id: UUID
    product_id: str
    name: str

app = faust.App('prdapp', broker='kafka://localhost:9092')
prd_topic = app.topic('products', key_type=str, value_type=Order)

@app.agent(prd_topic)
async def process_product(prds):
    async for p in prds:
        print(f'product_id with uuid - {p.id}, ID is {p.product_id} and name is {p.name}')
...