mekhicode

Results 1 issues of mekhicode

from faust import App, Record from faust.web import Request, Response, View import asyncio app = App('ness', broker='kafka://localhost') data_queues = {} async def process_message(stream): async for record in stream: yield record...