如何解决dbt-postgres适配器对接Cockroach DB（CRDB）的事务错误？

问题根源 #

CockroachDB（CRDB）与PostgreSQL的事务处理机制存在差异，dbt-postgres适配器的默认事务逻辑无法完全适配CRDB，导致即使执行show transaction status返回NoTxn，仍会触发"there is already a transaction in progress"错误。

针对性解决方案 #

1. 调整dbt事务配置（快速验证）

在dbt_project.yml中针对CRDB模型关闭自动事务，避免适配器重复启动事务：

# 仅对CRDB相关模型生效（建议用目录/标签区分）
models:
  your_project_name:
    crdb_models:
      +transactions: false

或对单个模型单独配置：

{{ config(transactions=false) }}

SELECT ... -- 模型业务逻辑

2. 切换至dbt-cockroachdb专用适配器

dbt社区已推出CRDB专属适配器，比dbt-postgres更适配CRDB的事务与语法特性，是长期最优方案：

• 安装适配器：pip install dbt-cockroachdb
• 修改profiles.yml配置：

  your_profile:
    target: dev
    outputs:
      dev:
        type: cockroachdb
        host: your_crdb_host
        user: your_user
        password: your_password
        database: your_db
        schema: your_schema
        port: 26257
        sslmode: require # 根据CRDB实际SSL配置调整
  

3. 自定义适配器事务逻辑（适配复杂环境）

若暂时无法切换适配器，可基于dbt-postgres重写事务处理逻辑：

• 创建自定义适配器文件dbt/adapters/crdb_adapter.py：

  from dbt.adapters.postgres import PostgresAdapter, PostgresConnectionManager
  
  class CrdbConnectionManager(PostgresConnectionManager):
      def begin(self):
          if not self.is_open():
              self.open()
          # 显式启动事务，适配CRDB的事务触发逻辑
          self.execute("BEGIN TRANSACTION;")
  
  class CrdbAdapter(PostgresAdapter):
      ConnectionManager = CrdbConnectionManager
  

• 在dbt_project.yml中指定适配器：

  adapter: crdb_adapter
  

  注意：需在组织内完成多场景测试，确保不影响其他数据库模型运行。

4. 模型级事务钩子（临时过渡）

对核心模型手动控制事务生命周期：

{{ config(
    pre_hook="BEGIN;",
    post_hook="COMMIT;"
) }}

SELECT ... -- 模型SQL逻辑

该方案适合小范围试点，不建议全量推广，避免增加维护成本。

组织级实施建议 #

• 分批迁移：先选择非核心模型验证方案稳定性，再逐步覆盖核心CRDB模型，降低业务风险。
• 跨团队协作：联合DBA监控CRDB事务日志，确保调整后的逻辑符合组织数据库规范。
• 长期规划：优先切换至dbt-cockroachdb适配器，跟进官方更新，减少自定义维护成本。

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