Redshift中如何关联游标对应的原始查询？含Tableau接入场景

可以通过Redshift系统表的递归关联逻辑，将Tableau生成的游标FETCH结果关联回原始业务查询，具体实现步骤如下：

核心原理 #

Tableau连接Redshift使用游标时，会在同一会话（session_id）和事务（txn_id）内生成三类关联查询：

1. DECLARE CURSOR FOR <原始业务查询>：定义游标并包含实际要执行的业务SQL
2. FETCH ... FROM <游标名>：分批获取游标结果
3. CLOSE <游标名>：关闭游标

通过Redshift的系统表追踪这些查询的会话/事务关联，即可将FETCH操作映射到对应的原始业务查询。

具体实现步骤 #

1. 依赖系统表说明 #

主要用到以下Redshift系统表：

• stl_query：记录所有执行过的查询的元数据（会话ID、事务ID、查询ID、查询文本等）
• stl_querytext：存储长查询的拆分文本（单条查询超过2000字符时会拆分到多行）
• svl_statementtext：可选，用于补充追踪更细粒度的语句执行

2. 关联逻辑与示例SQL #

-- 提取DECLARE CURSOR查询的基础信息
WITH cursor_declares AS (
    SELECT 
        q.session_id,
        q.txn_id,
        q.query_id AS declare_query_id,
        -- 解析游标名称（适配Tableau生成的SQL格式）
        regexp_substr(q.query_text, 'DECLARE\s+(\w+)\s+CURSOR', 1, 1, 'e') AS cursor_name
    FROM stl_query q
    WHERE q.query_text ILIKE '%DECLARE%CURSOR%'
      AND q.user_name = 'tableau_service_user' -- 替换为你的Tableau连接用户
),
-- 关联同会话/事务的FETCH查询
cursor_fetches AS (
    SELECT 
        q.session_id,
        q.txn_id,
        q.query_id AS fetch_query_id,
        regexp_substr(q.query_text, 'FETCH\s+.*\s+FROM\s+(\w+)', 1, 1, 'e') AS cursor_name
    FROM stl_query q
    WHERE q.query_text ILIKE '%FETCH%FROM%'
      AND q.user_name = 'tableau_service_user'
),
-- 拼接完整DECLARE语句并提取原始业务查询
cursor_linked AS (
    SELECT 
        cd.session_id,
        cd.txn_id,
        cd.declare_query_id,
        cf.fetch_query_id,
        cd.cursor_name,
        -- 拼接长查询的完整文本
        LISTAGG(qt.text, '') WITHIN GROUP (ORDER BY qt.seq) AS full_declare_sql,
        -- 提取FOR之后的原始业务SQL
        regexp_replace(
            LISTAGG(qt.text, '') WITHIN GROUP (ORDER BY qt.seq),
            '.*DECLARE\s+\w+\s+CURSOR\s+FOR\s+(.*)',
            '\1',
            1,
            1,
            'e'
        ) AS original_business_sql
    FROM cursor_declares cd
    JOIN cursor_fetches cf 
        ON cd.session_id = cf.session_id 
        AND cd.txn_id = cf.txn_id 
        AND cd.cursor_name = cf.cursor_name
    JOIN stl_querytext qt 
        ON cd.declare_query_id = qt.query_id
    GROUP BY cd.session_id, cd.txn_id, cd.declare_query_id, cf.fetch_query_id, cd.cursor_name
)
-- 输出最终关联结果
SELECT 
    original_business_sql,
    fetch_query_id,
    declare_query_id,
    session_id,
    txn_id
FROM cursor_linked
ORDER BY session_id, txn_id;

3. 扩展与注意事项 #

• 正则适配：不同版本的Tableau生成的游标SQL格式可能略有差异，需要根据实际的query_text调整正则表达式，确保能准确解析游标名称和原始查询。
• 权限要求：执行该SQL需要拥有Redshift系统表的查询权限，可通过GRANT SELECT ON stl_query, stl_querytext TO your_analysis_user;授权。
• 日志保留：Redshift系统表的查询日志默认保留时间有限（通常数天到数周），如果需要长期分析，建议将日志定期导出到S3或专用分析表存储。
• 递归追踪依赖：如果原始业务查询引用了临时表或其他对象，可进一步关联svl_dependency表，追踪临时表的创建语句，构建完整的查询链路。

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