tencent cloud

数据开发治理平台 WeData

文档数据开发治理平台 WeData操作指南项目管理系统表开发运维系统表

开发运维系统表

Download
聚焦模式
字号
最后更新时间： 2026-04-24 16:39:59

使用要求

在访问和使用 WeData 系统表之前，必须满足以下条件：
1. 数据源要求：必须使用 DLC 数据源，其他数据源暂不支持系统表能力。
2. Catalog 要求：访问系统表必须使用 tc-catalog。

系统表列表概览

WeData 支持两种调度模式：任务调度模式和工作流调度模式，两种模式在项目创建时配置，不可修改。不同调度模式下可用的系统表有所不同。

任务调度模式

任务调度模式下提供的系统表及其更新频率如下：
表名
描述
更新频率
task
包含编排空间下任务的基础信息（开发态）。
5分钟
task_schedule
包含编排空间下任务的调度信息（开发态）。
5分钟
task_dependency
包含编排空间下任务的依赖关系（开发态）。
5分钟
workflow
包含编排空间下工作流的基础信息（开发态）。
5分钟
task_run_record
包含运维中心所有实例运行记录信息。
5分钟
parameter
参数表，包含项目参数、工作流参数、任务参数（工作流和任务参数为开发态）。
5分钟

工作流调度模式

工作流调度模式下提供的系统表及其更新频率如下：
表名
描述
更新频率
trigger_task
包含工作流调度模式下任务的基础信息（开发态）。
5分钟
trigger_workflow
包含工作流调度模式下工作流的基础信息及调度配置（开发态）。
5分钟
trigger_workflow_schedule
包含工作流调度模式下工作流的调度信息。
5分钟
trigger_task_run_record
包含工作流调度模式下任务运行记录信息。
5分钟
trigger_workflow_run_record
包含工作流调度模式下工作流运行记录信息。
5分钟
parameter
参数表，包含项目参数、工作流参数、任务参数（工作流和任务参数为开发态）。
5分钟

系统表详细说明（任务调度模式）

task（任务基础信息表）

表路径：system_catalog.wedata.task
字段结构：
列名
数据类型
描述
project_id
string
项目 ID
project_name
string
项目名称
task_id
string
任务 ID
task_name
string
任务名称
task_type
string
任务类型
status
string
任务状态
owner
string
任务负责人
workflow_id
string
所属工作流 ID
workflow_name
string
所属工作流名称
schedule_frequency
string
调度频率
create_timestamp
timestamp_tz(6)
任务创建时间
last_update_timestamp
timestamp_tz(6)
最近一次更新时间
last_update_user
string
最近一次更新用户
data_source
string
数据源
dlc_data_engine
string
DLC 数据引擎
dlc_resource_group
string
DLC 资源组
execution_resource_group
string
执行资源组
查询示例：
查询特定项目负责人下的任务。
SELECT
    task_id,
    task_name,
    task_type,
    status,
    workflow_name
FROM
    wedata.task
WHERE
    project_id = 'your_project_id'   -- Replace with your project ID
    AND owner = 'your_owner_name';  -- Replace with your owner name

task_schedule（任务调度信息表）

表路径：system_catalog.wedata.task_schedule
字段结构：
列名
数据类型
描述
project_id
string
项目 ID
project_name
string
项目名称
task_id
string
任务 ID
task_name
string
任务名称
config_method
string
任务所属工作流类型：<br>PERIODICALLY：周期工作流<br>MANUALLY：手动工作流
schedule_cycle_type
string
调度配置方式：<br>COMMON：常规配置<br>CRON_EXPRESSION：使用 cron 表达式配置
effective_start_time
timestamp_tz(6)
生效时间-开始时间
effective_end_time
timestamp_tz(6)
生效时间-结束时间
schedule_frequency
string
调度周期：<br>ONEOFF_CYCLE: 一次性<br>YEAR_CYCLE: 年<br>MONTH_CYCLE: 月<br>WEEK_CYCLE: 周<br>DAY_CYCLE: 天<br>HOUR_CYCLE: 小时<br>MINUTE_CYCLE: 分钟<br>CRONTAB_CYCLE: crontab 表达式类型
delay_time
long
调度延迟时间，单位为分钟：<br>分钟任务该字段为0，表示不延迟<br>小时任务表示每小时0分开始延迟几分钟执行<br>天、周、月、年任务表示从0点开始延迟几分钟执行
execution_start_time
string
执行时间-开始时间
execution_end_time
string
执行时间-结束时间
cycle_step
long
调度频率：<br>例如分钟任务，20表示每隔20分钟调度一次<br>天任务，1表示每天调度一次
time_point
string
指定调度时间点<br>例如小时调度任务配置指定运行时间点时的配置
time_zone
string
调度时区
cron
string
cron 表达式，仅针对 cron 配置方式的任务
查询示例：
查询特定项目中调度周期为一天的任务列表。
SELECT
    project_id,
    project_name,
    task_id,
    task_name,
    config_method,
    schedule_cycle_type,
    effective_start_time,
    effective_end_time,
    schedule_frequency
FROM
    wedata.task_schedule
WHERE
    project_id = 'your_project_id'       -- Replace with your project ID
    AND schedule_frequency = 'DAY_CYCLE';

task_dependency（任务依赖关系表）

表路径：system_catalog.wedata.task_dependency
字段结构：
列名
数据类型
描述
project_id
string
项目 ID
project_name
string
项目名称
task_id
string
任务 ID
task_name
string
任务名称
dependency_project_id
string
上游任务所属项目 ID
dependency_project_name
string
上游任务所属项目名称
dependency_task_id
string
上游任务 ID
dependency_task_name
string
上游任务名称
查询示例：
获取某个任务的直接上游任务。
SELECT
    dependency_project_id AS upstream_project_id,
    dependency_project_name AS upstream_project_name,
    dependency_task_id AS upstream_task_id,
    dependency_task_name AS upstream_task_name
FROM
    wedata.task_dependency
WHERE
    task_id = 'your_task_id';  -- Replace with your task ID

workflow（工作流基础信息表）

表路径：system_catalog.wedata.workflow
字段结构：
列名
数据类型
描述
project_id
string
项目 ID
project_name
string
项目名称
workflow_id
string
所属工作流 ID
workflow_name
string
所属工作流名称
workflow_type
string
工作流类型：周期工作流/手动工作流
folder
string
工作流所属文件夹
create_time
timestamp_tz(6)
工作流创建时间
last_update_timestamp
timestamp_tz(6)
最近一次更新时间
last_update_user
string
最近一次更新人
owner
string
工作流负责人
查询示例：
查询特定用户名下的工作流列表。
SELECT
    workflow_id,
    workflow_name,
    workflow_type
FROM
    wedata.workflow
WHERE
    owner = 'your_owner_name';  -- Replace with your owner name

task_run_record（任务实例运行记录表）

表路径：system_catalog.wedata.task_run_record
字段结构：
列名
数据类型
描述
task_run_id
string
任务实例 ID
task_id
string
任务 ID
task_name
string
任务名称
project_id
string
任务所属项目 ID
project_name
string
任务所属项目名称
workflow_id
string
任务所属工作流 ID
workflow_name
string
任务所属工作流名称
dp_data_dt
timestamp_tz(6)
计划调度时间
task_run_status
string
实例状态
run_min
string
运行时长
run_start_dttm
timestamp_tz(6)
运行开始时间
run_end_dttm
timestamp_tz(6)
运行结束时间
run_log_url
string
实例详情页-执行日志的产品链接
task_run_error_msg
string
关键错误日志
last_update_timestamp
timestamp_tz(6)
最近一次更新时间
last_update_user
string
最近一次更新人
查询示例：
示例 1：统计过去 7 天每个工作流的任务实例运行次数。
SELECT
    workflow_name,
    COUNT(task_run_id) AS instance_count
FROM
    wedata.task_run_record
WHERE
    run_start_dttm >= CURRENT_DATE - INTERVAL '7' DAY
GROUP BY
    workflow_name;
示例 2：获取平均运行时长最长的 10 个任务。
SELECT
    task_name,
    AVG(run_min) AS avg_run_min
FROM
    wedata.task_run_record
WHERE
    run_min IS NOT NULL
GROUP BY
    task_name
ORDER BY
    avg_run_min DESC
LIMIT 10;

parameter（参数信息表）

表路径：system_catalog.wedata.parameter
说明：
参数信息表在任务调度模式和工作流调度模式下均可使用，表结构相同。
字段结构：
列名
数据类型
描述
name
string
项目/任务/工作流名称
id
string
项目/任务/工作流 ID
level
string
参数级别：<br>TASK：任务级别<br>PROJECT：项目级别<br>WORKFLOW：工作流级别
param_name
string
参数名称
param_value_dev
string
开发态对应参数值
param_value_prod
string
生产态对应参数值
查询示例：
获取任务中实际使用的参数及其对应值（包含任务、工作流和项目级别的参数解析）。
WITH task_params AS (
    SELECT
        p.param_name,
        p.param_value_dev AS dev_value,
        p.param_value_prod AS prod_value,
        'TASK' AS param_level
    FROM
        wedata.parameter p
    JOIN
        wedata.task t ON p.id = t.task_id
    WHERE
        t.task_id = 'task_id'        -- Replace with your task ID
        AND p.level = 'TASK'
),
workflow_params AS (
    SELECT
        p.param_name,
        p.param_value_dev AS dev_value,
        p.param_value_prod AS prod_value,
        'WORKFLOW' AS param_level
    FROM
        wedata.parameter p
    JOIN
        wedata.task t ON p.id = t.workflow_id
    WHERE
        t.task_id = 'task_id'        -- Replace with your task ID
        AND p.level = 'WORKFLOW'
),
project_params AS (
    SELECT
        p.param_name,
        p.param_value_dev AS dev_value,
        p.param_value_prod AS prod_value,
        'PROJECT' AS param_level
    FROM
        wedata.parameter p
    JOIN
        wedata.task t ON p.id = t.project_id
    WHERE
        t.task_id = 'task_id'        -- Replace with your task ID
        AND p.level = 'PROJECT'
),
all_params AS (
    SELECT * FROM task_params
    UNION ALL
    SELECT * FROM workflow_params
    UNION ALL
    SELECT * FROM project_params
)
SELECT
    param_name,
    dev_value,
    prod_value,
    param_level
FROM (
    SELECT
        param_name,
        dev_value,
        prod_value,
        param_level,
        ROW_NUMBER() OVER (
            PARTITION BY param_name
            ORDER BY CASE
                WHEN param_level = 'TASK' THEN 1
                WHEN param_level = 'WORKFLOW' THEN 2
                WHEN param_level = 'PROJECT' THEN 3
            END
        ) AS rn
    FROM
        all_params
) ranked_params
WHERE
    rn = 1;

系统表详细说明（工作流调度模式）

说明：
以下系统表仅在工作流调度模式的项目中可用。工作流调度模式下，调度配置在工作流粒度进行，任务粒度不支持配置调度。所有表的负责人和创建人均为 System user，且不可修改。

trigger_task（工作流调度任务基础信息表）

表路径：system_catalog.wedata.trigger_task
描述：包含工作流调度模式下编排空间中任务的基础信息（开发态）。
字段结构：
列名
数据类型
描述
project_id
string
项目 ID
project_name
string
项目名称
task_id
string
任务 ID
task_name
string
任务名称
task_type
string
任务类型
owner
string
任务负责人
workflow_name
string
所属工作流名称
workflow_id
string
所属工作流 ID
create_timestamp
timestamp_tz(6)
任务创建时间
last_update_timestamp
timestamp_tz(6)
最近一次更新时间
last_update_user
string
最近一次更新用户
data_source
string
数据源名称
dlc_data_engine
string
DLC 数据引擎
execution_resource_group
string
资源组（调度资源组或集成资源组）
dlc_resource_group
string
DLC 资源组
查询示例：
查询特定项目中某负责人下的所有任务。
SELECT
    task_id,
    task_name,
    task_type,
    workflow_name,
    workflow_id
FROM
    wedata.trigger_task
WHERE
    project_id = 'your_project_id'   -- Replace with your project ID
    AND owner = 'your_owner_name';  -- Replace with your owner name
查询特定工作流下的所有任务。
SELECT
    task_id,
    task_name,
    task_type,
    owner,
    data_source,
    execution_resource_group
FROM
    wedata.trigger_task
WHERE
    workflow_id = 'your_workflow_id';  -- Replace with your workflow ID

trigger_workflow（工作流调度工作流信息及调度配置表）

表路径：system_catalog.wedata.trigger_workflow
描述：包含工作流调度模式下工作流的基础信息及调度配置（开发态）。调度配置在工作流粒度进行，因此调度相关字段整合到了工作流表中。
字段结构：
列名
数据类型
描述
project_id
string
项目 ID
project_name
string
项目名称
workflow_id
string
工作流 ID
workflow_name
string
工作流名称
workflow_type
string
工作流类型：周期/手动
folder
string
工作流所属文件夹
create_time
timestamp_tz(6)
工作流创建时间
last_update_timestamp
timestamp_tz(6)
最近一次更新时间
last_update_user
string
最近一次更新用户
owner
string
工作流负责人
trigger_method
string
触发方式（定时触发/文件到达触发）
schedule_cycle_type
string
配置方式：常规/cron
schedule_frequency
string
调度频率
time_zone
string
调度时区
effective_start_time
timestamp_tz(6)
生效时间-开始时间
effective_end_time
timestamp_tz(6)
生效时间-结束时间
execution_time
string
执行时间
cron
string
cron 表达式，仅针对 cron 配置方式的工作流
说明：
trigger_workflow 表同时包含了工作流基础信息和调度配置信息。trigger_method 字段标识了触发方式，支持定时触发和文件到达触发两种方式。
查询示例：
查询特定用户名下的工作流及调度配置。
SELECT
    workflow_id,
    workflow_name,
    trigger_method,
    schedule_frequency,
    time_zone,
    cron
FROM
    wedata.trigger_workflow
WHERE
    owner = 'your_owner_name';  -- Replace with your owner name
查询所有使用定时触发的工作流。
SELECT
    workflow_id,
    workflow_name,
    schedule_frequency,
    effective_start_time,
    effective_end_time,
    execution_time,
    time_zone
FROM
    wedata.trigger_workflow
WHERE
    project_id = 'your_project_id'         -- Replace with your project ID
    AND trigger_method = '定时触发';
查询使用 cron 表达式配置的工作流。
SELECT
    workflow_id,
    workflow_name,
    cron,
    time_zone,
    effective_start_time,
    effective_end_time
FROM
    wedata.trigger_workflow
WHERE
    project_id = 'your_project_id'         -- Replace with your project ID
    AND schedule_cycle_type = 'cron';

trigger_workflow_schedule（工作流调度信息表）

表路径：system_catalog.wedata.trigger_workflow_schedule
描述：包含工作流调度模式下工作流的调度信息。
字段结构：
列名
数据类型
描述
project_id
string
项目 ID
project_name
string
项目名称
workflow_id
string
工作流 ID
workflow_name
string
工作流名称
trigger_id
string
触发器 ID
trigger_method
string
触发方式
schedule_cycle_type
string
配置方式
schedule_frequency
string
调度频率
time_zone
string
调度时区
effective_start_time
timestamp_tz(6)
生效时间-开始时间
effective_end_time
timestamp_tz(6)
生效时间-结束时间
cron
string
cron 表达式
file_arrival_path
string
文件到达路径
trigger_minimum_interval_second
long
触发最小间隔时间（秒）
trigger_wait_time_second
long
触发等待时间（秒）
last_update_timestamp
timestamp_tz(6)
最近一次更新时间
last_update_user
string
最近一次更新用户
查询示例：
查询特定项目中所有工作流的调度配置信息。
SELECT
    workflow_id,
    workflow_name,
    trigger_id,
    trigger_method,
    schedule_frequency,
    cron,
    time_zone
FROM
    wedata.trigger_workflow_schedule
WHERE
    project_id = 'your_project_id';  -- Replace with your project ID
查询所有使用文件到达触发的工作流调度配置。
SELECT
    workflow_id,
    workflow_name,
    trigger_id,
    file_arrival_path,
    trigger_minimum_interval_second,
    trigger_wait_time_second
FROM
    wedata.trigger_workflow_schedule
WHERE
    project_id = 'your_project_id'         -- Replace with your project ID
    AND trigger_method = '文件到达触发';
查询使用 cron 表达式配置的工作流调度信息。
SELECT
    workflow_id,
    workflow_name,
    trigger_id,
    cron,
    time_zone,
    effective_start_time,
    effective_end_time
FROM
    wedata.trigger_workflow_schedule
WHERE
    project_id = 'your_project_id'         -- Replace with your project ID
    AND schedule_cycle_type = 'cron';

trigger_task_run_record（工作流调度任务运行记录表）

表路径：system_catalog.wedata.trigger_task_run_record
描述：包含工作流调度模式下任务运行的记录信息。
字段结构：
列名
数据类型
描述
task_run_id
string
任务运行 ID
task_id
string
任务 ID
task_name
string
任务名称
project_id
string
任务所属项目 ID
project_name
string
任务所属项目名称
workflow_id
string
任务所属工作流 ID
workflow_name
string
任务所属工作流名称
task_run_status
string
任务运行状态
run_min
string
运行时长
run_start_dttm
timestamp_tz(6)
运行开始时间
run_end_dttm
timestamp_tz(6)
运行结束时间
run_log_url
string
任务运行详情页-执行日志的产品链接
task_run_error_msg
string
关键错误日志
last_update_timestamp
timestamp_tz(6)
最近一次更新时间
last_update_user
string
最近一次更新用户
查询示例：
示例 1：统计过去 7 天每个工作流下任务的运行次数。
SELECT
    workflow_name,
    COUNT(task_run_id) AS run_count
FROM
    wedata.trigger_task_run_record
WHERE
    run_start_dttm >= CURRENT_DATE - INTERVAL '7' DAY
GROUP BY
    workflow_name;
示例 2：获取平均运行时长最长的 10 个任务。
SELECT
    task_name,
    AVG(run_min) AS avg_run_min
FROM
    wedata.trigger_task_run_record
WHERE
    run_min IS NOT NULL
GROUP BY
    task_name
ORDER BY
    avg_run_min DESC
LIMIT 10;
示例 3：查询运行失败的任务及其错误日志。
SELECT
    task_run_id,
    task_name,
    workflow_name,
    task_run_status,
    run_start_dttm,
    run_end_dttm,
    task_run_error_msg
FROM
    wedata.trigger_task_run_record
WHERE
    project_id = 'your_project_id'   -- Replace with your project ID
    AND task_run_status = '失败';

trigger_workflow_run_record（工作流运行记录表）

表路径：system_catalog.wedata.trigger_workflow_run_record
描述：包含工作流调度模式下工作流运行的记录信息。这是工作流调度模式下新增的系统表，用于记录每次工作流运行（包括周期调度触发和手动触发）的执行情况。
字段结构：
列名
数据类型
描述
project_id
string
项目 ID
project_name
string
项目名称
workflow_id
string
工作流 ID
workflow_name
string
工作流名称
workflow_run_id
string
工作流运行 ID
workflow_run_status
string
工作流运行状态（等待中/运行中/成功/失败）
run_min
string
运行时长
run_start_dttm
timestamp_tz(6)
运行开始时间
run_end_dttm
timestamp_tz(6)
运行结束时间
trigger_method
string
触发方式（手动触发/调度触发）
run_log_url
string
工作流运行详情页链接
last_update_timestamp
timestamp_tz(6)
最近一次更新时间
last_update_user
string
最近一次更新用户
查询示例：
示例 1：查询特定工作流的运行历史记录。
SELECT
    workflow_run_id,
    workflow_run_status,
    trigger_method,
    run_start_dttm,
    run_end_dttm,
    run_min
FROM
    wedata.trigger_workflow_run_record
WHERE
    workflow_id = 'your_workflow_id'  -- Replace with your workflow ID
ORDER BY
    run_start_dttm DESC;
示例 2：统计过去 7 天工作流运行的成功率。
SELECT
    workflow_name,
    COUNT(*) AS total_runs,
    SUM(CASE WHEN workflow_run_status = '成功' THEN 1 ELSE 0 END) AS success_count,
    ROUND(
        SUM(CASE WHEN workflow_run_status = '成功' THEN 1 ELSE 0 END) * 100.0 / COUNT(*), 2
    ) AS success_rate
FROM
    wedata.trigger_workflow_run_record
WHERE
    run_start_dttm >= CURRENT_DATE - INTERVAL '7' DAY
GROUP BY
    workflow_name
ORDER BY
    success_rate ASC;
示例 3：获取平均运行时长最长的 10 个工作流。
SELECT
    workflow_name,
    AVG(run_min) AS avg_run_min,
    COUNT(*) AS run_count
FROM
    wedata.trigger_workflow_run_record
WHERE
    run_min IS NOT NULL
GROUP BY
    workflow_name
ORDER BY
    avg_run_min DESC
LIMIT 10;
示例 4：查询运行失败的工作流及其详情链接。
SELECT
    workflow_run_id,
    workflow_name,
    trigger_method,
    run_start_dttm,
    run_end_dttm,
    run_log_url
FROM
    wedata.trigger_workflow_run_record
WHERE
    project_id = 'your_project_id'   -- Replace with your project ID
    AND workflow_run_status = '失败'
ORDER BY
    run_start_dttm DESC;
上一篇: 系统表概述下一篇: 基础系统表

帮助和支持

本页内容是否解决了您的问题？

填写满意度调查问卷，共创更好文档体验。

文档反馈