如何在dbt中对多字符串列执行Pivot（透视）操作？

针对你的场景，dbt_utils.pivot()默认适配数值列的聚合操作，而你的RGB/HEX是字符串类型，且需要同时透视多列，可通过以下三种方式解决：

方法一：原生SQL条件聚合（最直观） #

利用MAX()/MIN()聚合字符串（因每个Project name + Main Color组合对应唯一值，聚合结果无歧义），手动编写条件分支实现透视：

WITH source_data AS (
    SELECT * FROM {{ ref('your_source_table') }} -- 替换为你的源表引用
)
SELECT
    "Project name",
    -- 针对blue的透视列
    MAX(CASE WHEN "Main Color" = 'blue' THEN RGB END) AS RGB_blue,
    MAX(CASE WHEN "Main Color" = 'blue' THEN HEX END) AS HEX_blue,
    -- 针对red的透视列
    MAX(CASE WHEN "Main Color" = 'red' THEN RGB END) AS RGB_red,
    MAX(CASE WHEN "Main Color" = 'red' THEN HEX END) AS HEX_red
FROM source_data
GROUP BY "Project name"

方法二：结合dbt_utils动态生成透视列（适配新增颜色） #

如果未来会新增颜色值，可通过Jinja模板+dbt_utils工具动态生成所有透视列，无需手动维护CASE语句：

{% set color_values = dbt_utils.get_column_values(
    table=ref('your_source_table'),
    column='Main Color'
) %}

WITH source_data AS (
    SELECT * FROM {{ ref('your_source_table') }}
)
SELECT
    "Project name",
    {% for color in color_values %}
        -- 生成RGB_xxx列
        MAX(CASE WHEN "Main Color" = '{{ color }}' THEN RGB END) AS RGB_{{ color }},
        -- 生成HEX_xxx列
        MAX(CASE WHEN "Main Color" = '{{ color }}' THEN HEX END) AS HEX_{{ color }}
        {% if not loop.last %},{% endif %}
    {% endfor %}
FROM source_data
GROUP BY "Project name"

方法三：扩展dbt_utils.pivot()的用法（官方工具适配） #

针对每一列单独调用dbt_utils.pivot()，指定字符串兼容的聚合函数（MAX/MIN）：

{% set color_values = dbt_utils.get_column_values(
    table=ref('your_source_table'),
    column='Main Color'
) %}

WITH source_data AS (
    SELECT * FROM {{ ref('your_source_table') }}
)
SELECT
    "Project name",
    -- 处理RGB列的透视
    {{ dbt_utils.pivot(
        column='Main Color',
        values=color_values,
        agg='MAX',
        then_value='RGB',
        alias_template='RGB_{{ value }}'
    ) }},
    -- 处理HEX列的透视
    {{ dbt_utils.pivot(
        column='Main Color',
        values=color_values,
        agg='MAX',
        then_value='HEX',
        alias_template='HEX_{{ value }}'
    ) }}
FROM source_data
GROUP BY "Project name"

关键注意事项 #

• 确保每个Project name + Main Color组合仅对应一条数据，否则MAX()/MIN()可能返回非预期结果（若存在重复数据，需先通过DISTINCT或去重逻辑处理）；
• 若颜色值包含空格、特殊字符，需在别名模板中做转义，例如{{ color | replace(' ', '_') }}避免列名非法。

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