相关疑难解决方法(0)

假设我有一个运行SQL查询并返回数据帧的函数:

import pandas.io.sql as psql
import sqlalchemy

query_string = "select a from table;"

def run_my_query(my_query):
    # username, host, port and database are hard-coded here
    engine = sqlalchemy.create_engine('postgresql://{username}@{host}:{port}/{database}'.format(username=username, host=host, port=port, database=database))

    df = psql.read_sql(my_query, engine)
    return df

# Run the query (this is what I want to memoize)
df = run_my_query(my_query)

我想要:

1. 能够通过每个值的一个缓存条目query_string(即每个查询)记忆我的查询
2. 能够根据需要强制缓存重置(例如,基于某些标志),例如,如果我认为数据库已更改,我可以更新我的缓存.

我怎么能用joblib,jug做到这一点？