django - 没有在 celery 任务中创建 Django 模型

Question

我有一个周期性的芹菜任务，它没有创建我的模型

@periodic_task(run_every=timedelta(seconds=1))
def store_products():
    products = get_products()
    for product in products:
        Product.objects.create(
            name=product['name'],
            description=product['body_html'],
            vendor=product['vendor'],
            rank=product['rank'],
            source=product['source'],
            price=product['variants'][0]['price'],
             product_id=product['id'],
        )

我的问题是我做错了什么

Answer 1

由于声誉低，我无法发表评论。但这可能会有所帮助 - 因为这是一个周期性任务“transaction.atomic”或具有“ISOLATION_LEVEL_SERIALIZABLE”只会在您通过 celery 在多个子进程中创建对象时产生问题。

从提供的信息中无法得出太多结论，但问题似乎在

products = get_products()

如果您从模型中获取一些数据而不使用其中的主键，则会产生问题。