我正在使用 Python 和 PyCharm，我试图使用 asyncio 卸载数据库写入，但在 IDE 警告方面遇到了麻烦。在我的 main.py 中，我以这种方式启动任务db_logging_monitoring_task =
我正在使用 Python 和 PyCharm，我试图卸载数据库写入， asyncio 但遇到了 IDE 警告问题
在我的 main.py 中，我以这种方式启动任务
db_logging_monitoring_task = asyncio.create_task(start_logging_jobs_sniffer())
tasks.append(db_logging_monitoring_task)
await gather(*tasks)
异步函数内部的 while 循环在 start_logging_jobs_sniffer 哪里
# Waits on jobs from a jobs_queue
async def start_logging_jobs_sniffer(self):
while True:
try:
job = await self.logging_jobs_queue.get()
# Adds jobs to a jobs_queue
async def make_logging_job(self, params):
job = self.LoggingJob(params)
await self.logging_jobs_queue.put(job)
类似地，在 main.py 中，我有另一个后台监控任务，该任务以 5 秒为间隔进行轮询，然后记录轮询结果
async def poll(self, interval: int):
if self.is_config_applied:
while True:
# ...
asyncio.create_task(make_logging_job(
params={
**self.polling_results
},
))
但 pycharm 向我发出警告
Coroutine 'create_task' is not awaited
我特别希望 make_logging_job 任务能够与其他任务并行工作，这就是我不使用的原因 await ，而且这似乎按预期工作。
如果我在出现警告的情况下运行程序，则它们 make_logging_job 似乎是并行的，并且不会阻止任何内容
我完全不明白为什么 PyCharm 会发出未等待的警告 create_task ，还有其他更好的方法来完成任务吗？
将任务保存到变量可以抑制错误，并且似乎通过在后台运行来发挥作用
test = asyncio.create_task(make_logging_job(
params={
**self.polling_results
},
))
但我不知道这有什么用，我认为将任务保存到变量不会等待协程
当您创建一个 asyncio 任务时，您不能只是“发射并忘记”它 - 您必须在某处保留对它的引用 - 并最终检查它是否完成，这样您就可以丢弃您的引用。
正如您发现的（在评论中） - 需要将任务归因于局部变量 - 但与您的 IDE 报告不同，这还不够 - 就像仅仅归因于变量并丢弃它一样，您没有任何参考。
使用一个容器，比如 set() ，并生成另一个任务来检查它们是否完成，也许使用一个 asyncio.wait 调用：
import asyncio
all_jobs = set()
async def poll(self, interval: int):
if self.is_config_applied:
while True:
# ...
all_jobs.add(asyncio.create_task(make_logging_job(
params={
**self.polling_results
},
)))
asyncio def task_waiter():
while True:
pending, done = await asyncio.wait(all_jobs, timeout=10) # collect once each 10 seconds - change at your will
all_jobs.clear()
all_jobs.update(pending)
# and wherever in your code, where you call `poll`, instead of
# just `await poll` do:
async def main(...):
...
# await poll(...) #old code, commented out
poll_task = asyncio.create_task(poll(...))
waiter_task = asyncio.create_task(task_waiter())
await asyncio.gather(poll_task, waiter_task)