似乎无法从芹菜任务修改缓存值

Question

描述：

我想要一个缓存值（让我们称之为 flag）来知道 celery 任务何时完成执行。我有一个视图让前端轮询此标志，直到它变成 False.

代码：

settings.py:

...
MEMCACHED_URL = os.getenv('MEMCACHED_URL', None) # Cache of devel or production
if MEMCACHED_URL:
    CACHES = {
        'default': {
            'BACKEND': 'django.core.cache.backends.memcached.MemcachedCache',
            'LOCATION': MEMCACHED_URL,
         }
    }
else:
    CACHES = {
        'default': {
            'BACKEND': 'django.core.cache.backends.locmem.LocMemCache',
            'LOCATION': 'unique-snowflake',
        }
    }

api/views.py:

def a_view(request):
    # Do some stuff
    cache.add(generated_flag_key, True)
    tasks.my_celery_task.apply_async([argument_1, ..., generated_flag_key])
    # Checking here with cache.get(generated_flag_key), the value is True.
    # Do other stuff.

tasks.py:

@shared_task
def my_celery_task(argument_1, ..., flag_cache_key):
    # Do stuff
    cache.set(flag_cache_key, False) # Checking here with 
                                     # cache.get(flag_cache_key),the
                                     # flag_cache_key value is False

views.py:

def get_cached_value(request, cache_key):
    value = cache_key.get(cache_key) # This remains True until the cache key 
                                     # expires.

问题：

如果我运行同步任务，一切都会按预期进行。当我异步运行任务时，缓存键保持不变（如预期的那样）并且它通过这 3 个方法正确传递，但缓存值似乎没有在任务和视图之间更新。

Answer 1

如果您运行您的任务是异步的，它们是不同进程的一部分，这意味着由于 LocMemCache 后端，任务和视图将不会使用相同的存储（每个都有自己的内存）。

Answer 2

由于@Linovia 的回答和对 Django 文档的深入研究，我现在使用 django-redis 作为我的案例的解决方法。

唯一需要更改的是 CACHES 设置（当然还有活动的 Redis 服务器！）：

settings.py:

CACHES = {
    "default": {
        "BACKEND": "django_redis.cache.RedisCache",
        "LOCATION": 'redis://127.0.0.1:6379/1',
        "OPTIONS": {
            "CLIENT_CLASS": "django_redis.client.DefaultClient",
        }
    }
}

现在缓存存储是单一的。
django-redis 是一个文档齐全的库，可以按照说明进行操作。

似乎无法从芹菜任务修改缓存值

Cannot seem able to modify cache value from celery task

python

django

django-cache

celery

django-rest-framework