将运行查询的结果存储到dbt中的表中

在dbt中，可以使用模板任务将查询结果存储到表中。以下是示例：

1. 创建模板任务

{% set my_query = "SELECT column1, column2 FROM my_table" %}

{% set my_table = "my_project.my_schema.my_results_table" %}

{{ dbt_utils.write_query_to_table( my_query, my_table, truncate=True, schema='my_schema' ) }}

2. 在 dbt_project.yml 中注册模板任务

models: my_model: materialized: sql sql: "{{ my_query }}" my_results_table: +schema: my_schema +tags: - permanent materialized: table sql: "{{ my_query }}" pre-hook: "{{ run_query('my_query') }}"

3. 运行任务

运行模板任务将自动运行my_query和my_results_table模型，并将查询结果写入表中。

{% set my_query = "SELECT COUNT(*) FROM my_table" %}

dbt run-operation write_query_to_table --args '{"query": "{{ my_query }}", "table": "my_project.my_schema.my_results_table", "truncate": true, "schema": "my_schema"}'