如何通过Windows Task Scheduler基于源表数据触发Teradata脚本执行？

由于Windows任务计划程序仅支持时间触发，无法直接基于数据库数据状态触发任务，我们可以通过**"定时触发检查脚本+脚本内判断数据状态"**的方式实现需求：让任务计划每隔15分钟执行一次检查脚本，脚本内判断源表是否有当日新数据，有则执行目标SQL脚本，无则直接退出。

以下是两种具体实现方式：

方式一：PowerShell脚本 + BTEQ工具 #

1. 编写检查与执行脚本 #

创建PowerShell脚本（如TD_DataCheck_Execute.ps1），利用Teradata的BTEQ工具完成数据检查和脚本执行：

# 配置Teradata连接参数
$tdServer = "你的Teradata服务器地址"
$tdUser = "数据库用户名"
$tdPassword = "数据库密码"
$sourceTable = "目标数据库.源表名"
$targetSqlScript = "C:\路径\你的目标SQL脚本.sql"

# 构建检查当日数据的SQL语句
$checkQuery = "SELECT COUNT(*) FROM $sourceTable WHERE CAST(你的日期字段名 AS DATE) = CURRENT_DATE;"

# 生成临时BTEQ检查脚本
$tempCheckScript = [System.IO.Path]::GetTempFileName()
@"
.LOGON $tdServer/$tdUser,$tdPassword;
$checkQuery;
.LOGOFF;
.EXIT;
"@ | Out-File $tempCheckScript -Encoding ASCII

# 执行BTEQ并捕获输出
$checkOutput = bteq < $tempCheckScript

# 清理临时文件
Remove-Item $tempCheckScript -Force

# 解析输出判断是否有新数据
if ($checkOutput -match "COUNT\(\*\)\s+(\d+)") {
    $recordCount = [int]$matches[1]
    if ($recordCount -gt 0) {
        # 存在新数据，执行目标SQL脚本
        $tempExecuteScript = [System.IO.Path]::GetTempFileName()
        @"
.LOGON $tdServer/$tdUser,$tdPassword;
RUN FILE $targetSqlScript;
.LOGOFF;
.EXIT;
"@ | Out-File $tempExecuteScript -Encoding ASCII
        
        bteq < $tempExecuteScript
        Remove-Item $tempExecuteScript -Force
        Write-Host "[$(Get-Date)] 检测到当日新数据，已成功执行目标SQL脚本"
    }
    else {
        Write-Host "[$(Get-Date)] 未检测到当日新数据，本次任务跳过"
    }
}
else {
    Write-Host "[$(Get-Date)] 数据检查查询执行失败，请检查连接或SQL语句"
}

2. 配置Windows任务计划程序 #

1. 打开任务计划程序，点击「创建任务」
2. 触发器选项卡：
   • 点击「新建」，选择「每天」，设置任务开始时间（如00:00）
   • 勾选「重复任务间隔」，选择15分钟，持续时间设为「24小时」
3. 操作选项卡：
   • 点击「新建」，操作选择「启动程序」
   • 程序/脚本输入：powershell.exe
   • 添加参数：-ExecutionPolicy Bypass -File "C:\路径\TD_DataCheck_Execute.ps1"
4. 设置选项卡：
   • 勾选「如果任务已经在运行，则不启动新实例」，避免重复执行
   • 配置运行任务的账户，确保该账户有权限访问Teradata服务器、读写脚本文件

方式二：批处理脚本 + BTEQ工具 #

如果更习惯批处理，也可以用以下脚本实现：

创建批处理文件（如TD_Check_Execute.bat）：

@echo off
setlocal enabledelayedexpansion

:: 配置参数
set "TD_SERVER=你的Teradata服务器地址"
set "TD_USER=数据库用户名"
set "TD_PWD=数据库密码"
set "SOURCE_TABLE=目标数据库.源表名"
set "TARGET_SCRIPT=C:\路径\你的目标SQL脚本.sql"
set "LOG_FILE=C:\路径\任务日志.log"

:: 记录日志时间
echo [%date% %time%] 开始执行数据检查 >> "%LOG_FILE%"

:: 生成BTEQ检查脚本
echo .LOGON !TD_SERVER!/!TD_USER!,!TD_PWD!; > check_data.bteq
echo SELECT COUNT(*) FROM !SOURCE_TABLE! WHERE CAST(你的日期字段名 AS DATE) = CURRENT_DATE; >> check_data.bteq
echo .LOGOFF; >> check_data.bteq
echo .EXIT; >> check_data.bteq

:: 执行检查并输出结果到临时文件
bteq < check_data.bteq > check_result.txt

:: 检查是否存在非零计数
findstr /R "COUNT\(\*\)\s+[1-9][0-9]*" check_result.txt >nul
if !errorlevel! equ 0 (
    echo [%date% %time%] 检测到当日新数据，开始执行目标脚本 >> "%LOG_FILE%"
    :: 生成执行脚本
    echo .LOGON !TD_SERVER!/!TD_USER!,!TD_PWD!; > execute_script.bteq
    echo RUN FILE !TARGET_SCRIPT!; >> execute_script.bteq
    echo .LOGOFF; >> execute_script.bteq
    echo .EXIT; >> execute_script.bteq
    bteq < execute_script.bteq >> "%LOG_FILE%" 2>&1
    del execute_script.bteq
) else (
    echo [%date% %time%] 未检测到当日新数据，任务结束 >> "%LOG_FILE%"
)

:: 清理临时文件
del check_data.bteq
del check_result.txt

endlocal

任务计划的配置与PowerShell方式一致，只需将操作中的程序/脚本改为该批处理文件路径即可。

注意事项 #

• 确保Teradata的BTEQ工具已安装，且其所在目录已添加到系统环境变量PATH中，否则任务计划无法找到bteq.exe
• 运行任务的账户需拥有：Teradata数据库访问权限、脚本文件读写权限、目标SQL脚本的执行权限
• 可通过日志文件记录任务执行状态，方便后续排查问题

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