Как разделить таблицу ошибок между несколькими агентами или таймерами ошибок? - PullRequest
Новая
       25

Как разделить таблицу ошибок между несколькими агентами или таймерами ошибок?

0 голосов
/ 25 сентября 2019

Я пытаюсь опубликовать данные (счет) таблицы faust в теме kafka через некоторый промежуток времени.Таймер работает, когда я публикую некоторую простую строку, но не может каким-то образом получить доступ к данным таблицы.Ниже приведен код таймера: 

@app.timer(interval=10.0)
async def publish_to_anomaly_topic():
            await anomaly_topic.send(
            value=str(page_views['total'].value())
          )
@app.agent(page_view_topic)
async def count_page_views(views):
    async for view in views.group_by(PageView.id):
        total=0
        page_views[view.id]+=1
        for everykey in list(page_views.keys()):
            if everykey != 'total':
                total+=page_views[everykey].value()
        page_views['total'] = total

Агент работает нормально.Я могу видеть значения правильно.

...