以下是一个使用aiohttp库进行无限流式处理的示例代码：

import aiohttp
import asyncio

async def stream_data(url):
    async with aiohttp.ClientSession() as session:
        async with session.get(url, timeout=None) as response:
            while True:
                chunk = await response.content.read(1024)
                if not chunk:
                    break
                # 处理数据块
                print(chunk)

async def main():
    url = "http://example.com/stream"  # 替换为实际的数据源URL
    await stream_data(url)

loop = asyncio.get_event_loop()
loop.run_until_complete(main())

在上面的示例中，我们使用aiohttp.ClientSession来创建一个异步HTTP客户端会话。在该会话中，我们使用session.get()方法发起一个GET请求，其中设置timeout=None以确保长时间等待期。

然后，我们使用异步循环来读取响应的数据块。在每个数据块中，我们可以进行适当的处理。在示例代码中，我们只是简单地打印出每个数据块。

最后，我们通过asyncio.get_event_loop()获取异步事件循环，并使用run_until_complete()运行主任务。

请注意，示例代码中的URL是一个示例URL，您需要将其替换为自己的数据源URL。同时，您可能需要根据您的实际需求进行适当的修改和扩展。