python - 尝试使用 faust 在 django 中创建一个 cronjob

Question

我正在尝试使用 faust 在 django 中创建一个 cronjob。如果我创建一个简单的 cronjob 在屏幕上打印一些东西，它可以工作，但如果我尝试使用一些 ORM 东西，它就不行。

@sync_to_async
def get_products():
    return Product.objects.filter(active=True)


@app.crontab('* * * * *')
async def run_very_minute():
    product = await get_products()
    print(product)

我也尝试这样做：

@app.crontab('* * * * *')
async def run_very_minute():
    products = await sync_to_async(list)(Product.objects.filter(active=True))
    print(product)

标签： pythondjangoasynchronousfaust