Python tensorflow：asyncio 或线程
Python tensorflow: asyncio or threading
我正在实施一个服务器，用于在 "semi-real" 时间内使用 tensorflow-gpu 识别照片中的对象。它将在 websocket 连接上侦听新照片，然后在空闲时将其排入检测器 运行 的列表中。使用 asyncio 或线程来处理 websocket 侦听器和识别队列会更简单吗？
我不是 threading/asyncio 方面的专家，但也许生成一个 Kafka 实例并拥有一段可以收听 Kafka 主题的代码会更容易吗？对于本主题，如果您已经将图像或图像路径存储在本地，您将推送图像或图像路径。此外，使用 consumer-groups 您将免费获得类似负载平衡的东西，因为它是 Kafka 的一部分。
最终我使用 asyncio 来处理 websocket 连接，将传入的图像排入队列。我使用了 threading，它有一个线程将图像读入 RAM，提取一些元数据，并将其排队等待对象检测器。另一个线程中的检测器 运行 标记图像并在数据库处理程序（又一个线程）中对标签进行排队。
我正在实施一个服务器，用于在 "semi-real" 时间内使用 tensorflow-gpu 识别照片中的对象。它将在 websocket 连接上侦听新照片，然后在空闲时将其排入检测器 运行 的列表中。使用 asyncio 或线程来处理 websocket 侦听器和识别队列会更简单吗？
我不是 threading/asyncio 方面的专家，但也许生成一个 Kafka 实例并拥有一段可以收听 Kafka 主题的代码会更容易吗？对于本主题，如果您已经将图像或图像路径存储在本地，您将推送图像或图像路径。此外，使用 consumer-groups 您将免费获得类似负载平衡的东西，因为它是 Kafka 的一部分。
最终我使用 asyncio 来处理 websocket 连接，将传入的图像排入队列。我使用了 threading，它有一个线程将图像读入 RAM，提取一些元数据，并将其排队等待对象检测器。另一个线程中的检测器 运行 标记图像并在数据库处理程序（又一个线程）中对标签进行排队。