Apache Beam调用BigQuery时报DATE与INT64类型不匹配错误

你在Python中拼接SQL时没有给reporting_date参数添加引号，导致SQL解析器将形如2021-11-14的日期字符串识别为算术表达式2021 - 11 - 14，计算得到整数值1996，自然无法完成INT64到DATE的类型转换。你在BigQuery控制台运行时给变量赋值加了引号，传入的是字符串类型，因此可以正常运行。

• 方案1：直接修改SQL拼接逻辑（快速生效）
  给拼接的日期参数外层添加单引号，将原有代码：

CAST({ known_args.reporting_date } as DATE)

修改为：

CAST('{ known_args.reporting_date }' as DATE)

也可以直接使用BigQuery的DATE函数简化写法：

DATE('{ known_args.reporting_date }')

• 方案2：使用参数化查询（更安全，避免SQL注入风险）
  不要在SQL中硬拼接参数，改用Apache Beam BigQuery连接器原生的参数传递能力：

1. SQL中直接使用参数占位符：

DATE_ADD(DATE(s.sys_update_date), INTERVAL 74 DAY) = @reporting_date

2. Python调用ReadFromBigQuery时传入参数配置：

p | beam.io.ReadFromBigQuery(
    query=你的SQL语句,
    use_standard_sql=True,
    query_parameters=[
        ('reporting_date', 'DATE', known_args.reporting_date)
    ]
)

该方案无需手动处理类型转换和引号拼接，是官方推荐的参数传递方式。

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