使用 django 和 celery 的全局变量

Question

我有这样的代码，

wl_data = {}

def set_wl_data():
    global wl_data
    wl_data = get_watchlist_data()


def get_wl_data(scripcodes):
    # Filtering Data
    result = {scripcode:detail for scripcode, detail in wl_data.iteritems() if int(scripcode) in scripcodes or scripcode in scripcodes}
    return result

我将其作为 django 项目运行， 我正在从 celery 调用 setter 方法，以更新全局变量 wl_data。
sweetpie api会调用getter方法get_wl_data来获取全局变量wl_data。

问题是 celery 正在正确更新 wl_data。 但是当我们在浏览器中点击tastepie api url时，getter方法 提供旧数据。

栈溢出的相关问题很多，这里的区别在于setter方法是由celery task调用的。请帮我解决这个问题。

Answer 1

如果您在 Django 项目中对全局变量进行任何操作，那么您做错了。在这种情况下，Celery 和 Django 运行在完全独立的进程中，因此无法共享数据。您需要让 Celery 将该数据存储在某处 - 在数据库中或文件中 - 以便 Django 可以获取并提供它。