SQLAlchemy传入过滤器触发TypeError错误排查

问题根源 #

你触发错误的核心原因是直接在if判断中使用了SQLAlchemy的查询条件对象。SQLAlchemy为了防止开发者误将查询条件当作普通布尔表达式使用，特意禁用了ClauseElement（所有查询条件的基类）的布尔值计算逻辑，所以当你写if filters:时，Python尝试计算该对象的布尔值就会抛出这个错误。

解决方案 #

把判断过滤器是否存在的逻辑，从直接判断布尔值改为检查参数是否为None：

原代码片段：

if filters:
    query=query.where(filters)

修改为：

if filters is not None:
    query=query.where(filters)

修改后的完整方法代码 #

def fetch_trade_data_by_allo_tn(session_maker, trade_columns: list, allo_tns, chunk_size=1000, filters=None):
    trades_df_list = []
    with session_maker() as session:
        for allo_chunk in chunk_list(allo_tns, chunk_size=chunk_size):
            query = select(*trade_columns).where(Trades.ALLO_TN.in_(allo_chunk))
            if filters is not None:
                query=query.where(filters)

            query = query.distinct()
            print(query)

            trades_df_chunk = pd.DataFrame(session.execute(query).fetchall())
            trades_df_list.append(trades_df_chunk)

    trades_df = pd.concat(trades_df_list)
    return trades_df

补充说明 #

你提到其他类似条件（如Trades.ORDER_NUM != 0）能正常运行，大概率是之前调用这些条件时没有直接用if判断其布尔值，或者场景中没有触发这个检查逻辑。但只要是SQLAlchemy的查询条件对象，直接用if判断都会触发这个错误，统一使用is not None的判断方式就能彻底避免这类问题。

内容的提问来源于stack exchange，提问作者max