2017-09-17 116 views
0

我在SSIS包中有四个顺序任务。如何在每10分钟后获取当前正在运行的任务的名称?如何获取ssis包中当前正在运行的任务的名称

+0

是不是执行历史报告还不够吗?它会告诉你执行过程中已经发生了什么,执行时间。如果你需要目前的任务,你可能需要*现在*。这份10分钟的旧记录已经在报道中 –

回答

0

以下是一个脚本,您可以使用该脚本来使用SQL Job代理来获取正在运行的package_name。然后,您可以创建一个ssis包来提取这些数据,然后在每10分钟运行一次的SQL JOB代理中进行设置。您可以在message_source_name看到任务名称

当前运行的程序包与TASKNAME:

USE SSISDB 
GO 
/* 
Configuration 
*/ 
    -- Filter data by execution id (use NULL for no filter) 

-- Show only Child Packages or everyhing 
DECLARE @showOnlyChildPackages BIT = 0; 
-- Show only message from a specific Message Source 
DECLARE @messageSourceName NVARCHAR(MAX)= '%' 

-- Filter data by project name (use % for no filter) 
DECLARE @projectNamePattern NVARCHAR(100) = '%' 
-- Filter data by package name (use % for no filter) 
DECLARE @packageNamePattern NVARCHAR(100) = '%' 
-- Filter data by execution id (use NULL for no filter) 
DECLARE @executionIdFilter BIGINT = NULL; 
with running as (

/* 
Implementation 
*/ 
-- Show last 15 executions 
SELECT TOP 15 
e.execution_id, 
e.project_name, 
e.package_name, 
e.project_lsn, 
e.status, 
status_desc = CASE e.status 
WHEN 1 THEN 'Created' 
WHEN 2 THEN 'Running' 
WHEN 3 THEN 'Cancelled' 
WHEN 4 THEN 'Failed' 
WHEN 5 THEN 'Pending' 
WHEN 6 THEN 'Ended Unexpectedly' 
WHEN 7 THEN 'Succeeded' 
WHEN 8 THEN 'Stopping' 
WHEN 9 THEN 'Completed' 
END, 
e.start_time, 
e.end_time, 
elapsed_time_min = datediff(mi, e.start_time, e.end_time) 
FROM 
catalog.executions e 
WHERE 
e.project_name LIKE @projectNamePattern 
AND 
e.package_name LIKE @packageNamePattern 
AND 
e.execution_id = ISNULL(@executionIdFilter, e.execution_id) 
and e.status = 2 


) 



select * from running a 
inner join 
(
    SELECT top 1 * FROM catalog.event_messages em 
WHERE ((em.operation_id = @executionIdFilter) OR @executionIdFilter IS NULL) 
--AND (em.event_name IN ('OnInformation', 'OnError', 'OnWarning')) 
AND (package_path LIKE CASE WHEN @showOnlyChildPackages = 1 THEN '\Package' ELSE '%' END) 
AND (em.message_source_name like @messageSourceName) 
order by operation_id desc,message_time desc 
) 
b on a.execution_id = b.operation_id 
相关问题