如何在后台运行无限循环？

问题描述

我有一个函数可以持续监控API。基本上，该函数获取数据，对其进行解析，然后将其附加到文件中。然后等待15分钟，并反复执行相同的操作。

我想要的是在后台运行此循环，这样我就不会对代码的睡觉执行进行挡路攻击。

---

解决方案

如果您正在使用Asyncio(我假设您是由于Asyncio标记)，则可以使用任务执行计划操作。

import asyncio

loop = asyncio.get_event_loop()

async def check_api():
    while True:
        # Do API check, helps if this is using async methods
        await asyncio.sleep(15 * 60)  # 15 minutes (in seconds)

loop.create_task(check_api())

...  # Rest of your application

loop.run_forever()

如果您的API检查不是异步的(或者您用来与其交互的库不是异步的)，您可以使用执行器在单独的线程或进程中运行操作，同时仍然维护异步API。

例如：

from concurrent.futures import ThreadPoolExecutor

executor = ThreadPoolExecutor()

def call_api():
    ...

async def check_api():
    while True:
        await loop.run_in_executor(executor, call_api)
        await asyncio.sleep(15 * 60)  # 15 minutes (in seconds)

请注意，Asyncio不会自动使您的代码并行，它是协作式多任务处理，您的所有方法都需要使用AWAIT进行协作，长期运行的操作仍会挡路其他线程，在这种情况下，执行器将提供帮助。