7

我在这个问题上摸不着头脑。

我有一个带有 Flask-Cache 和 SqlAlchemy 的 Flask 应用程序：

app = Flask(__name__)
app.config['SQLALCHEMY_DATABASE_URI'] = 'postgresql+pg8000://[Redacted]
cache = Cache(app, config={'CACHE_TYPE':'redis', 'CACHE_REDIS_URL':'[Redacted]'})
db = SQLAlchemy(app)

芹菜工人：

@worker_process_init.connect
def init_worker(**kwargs):
    global db_session
    print('Initializing database connection for worker.')
    db_session = database.get_session()


@worker_process_shutdown.connect
def shutdown_worker(**kwargs):
    global db_session
    if db_session.is_active:
        print('Closing database connectionn for worker.')
        db_session.close()

还有一个通用的 get_or_create def：

@cache.cached(timeout=200, key_prefix="get_or_create")
def get_or_create(model, **kwargs):
    instance = model.query.filter_by(**kwargs).first()
    if instance:
        return instance
    else:
        instance = model(**kwargs)
        db_session.add(instance)
        return instance

我正在尝试使用缓存来解决导致 UniqueConstraint 违规的多处理（即，当两个工作人员同时插入非唯一对象时，一个应该在第一个插入后更新）

工人们在吐

InvalidRequestError：实例“<[Redacted]>”在此会话中不持久

我能弄清楚的最好的事情是我需要扩大会议的范围吗？

4

0 回答 0