[SQL Server]自动监控“发布订阅”的滞后时间(延迟时间)

比眉伴天荒 2022-09-29 13:56 242阅读 0赞

在发布服务器上，执行如下代码：

DECLARE@tokenID int;

\-- 在发布项目中,插入一个跟踪令牌(过期时间和其它事务一样,过期后会自动删除)

EXECUserCenter.sys.sp\_posttracertoken \-- 执行的数据库,为发布项目对应的数据库

@publication= 'UserCenter',            \-- 发布项目名

@tracer\_token\_id = @tokenID OUTPUT;    \-- 返回一个令牌id

print@tokenID

\-- 过一小段时间后,根据这个令牌id, 查询一下跟踪结果.

EXECUserCenter.sys.sp\_helptracertokenhistory

@publication= 'UserCenter',

@tracer\_id = @tokenID ;

返回结果如下：

<table style="width: 100%; background: #cccccc; mso-cellspacing: 0cm; mso-padding-alt: 0cm 0cm 0cm 0cm;"> 
 <tbody> 
 <tr style="mso-yfti-irow: 0; mso-yfti-firstrow: yes;"> 
 <td style="background-color: transparent; border: #ebe9ed; padding: 0cm;"> 列名 </td> 
 <td style="background-color: transparent; border: #ebe9ed; padding: 0cm;"> 数据类型 </td> 
 <td style="background-color: transparent; border: #ebe9ed; padding: 0cm;"> 说明 </td> 
 </tr> 
 <tr style="mso-yfti-irow: 1;"> 
 <td style="background-color: transparent; border: #ebe9ed; padding: 0cm;"> distributor_latency </td> 
 <td style="background-color: transparent; border: #ebe9ed; padding: 0cm;"> bigint </td> 
 <td style="background-color: transparent; border: #ebe9ed; padding: 0cm;"> 发布服务器提交至“分发服务器”延迟秒数 </td> 
 </tr> 
 <tr style="mso-yfti-irow: 2;"> 
 <td style="background-color: transparent; border: #ebe9ed; padding: 0cm;"> subscriber </td> 
 <td style="background-color: transparent; border: #ebe9ed; padding: 0cm;"> sysname </td> 
 <td style="background-color: transparent; border: #ebe9ed; padding: 0cm;"> 接收跟踪令牌的订阅服务器的名称。 </td> 
 </tr> 
 <tr style="mso-yfti-irow: 3;"> 
 <td style="background-color: transparent; border: #ebe9ed; padding: 0cm;"> subscriber_db </td> 
 <td style="background-color: transparent; border: #ebe9ed; padding: 0cm;"> sysname </td> 
 <td style="background-color: transparent; border: #ebe9ed; padding: 0cm;"> 在其中插入跟踪令牌记录的订阅数据库的名称。 </td> 
 </tr> 
 <tr style="mso-yfti-irow: 4;"> 
 <td style="background-color: transparent; border: #ebe9ed; padding: 0cm;"> subscriber_latency </td> 
 <td style="background-color: transparent; border: #ebe9ed; padding: 0cm;"> bigint </td> 
 <td style="background-color: transparent; border: #ebe9ed; padding: 0cm;"> 分发服务器 至 订阅服务器 延迟的秒数 </td> 
 </tr> 
 <tr style="mso-yfti-irow: 5; mso-yfti-lastrow: yes;"> 
 <td style="background-color: transparent; border: #ebe9ed; padding: 0cm;"> overall_latency </td> 
 <td style="background-color: transparent; border: #ebe9ed; padding: 0cm;"> bigint </td> 
 <td style="background-color: transparent; border: #ebe9ed; padding: 0cm;"> 总延迟的秒数. </td> 
 </tr> 
 </tbody> 
</table>

--------------------

createtable t\_config\_publication(

dbname              varchar(50) primary key,  \-- 发布项目名称,同时也必须是发布数据库的名称

is\_enable           int                       \-- 1:打开, 0关闭

);

createtable t\_log\_publication(

writetime           datetime    not null,    \--写日志时间(设置发布跟踪的时间)

dbname              varchar(50) not null,    \--发布项目名称,同时也必须是发布数据库的名称

token\_id            int unique,              \--跟踪令牌号

distributor\_latency bigint,                  \--发布至分发滞后时间(秒数)

subscriber\_latency  bigint,                  \--分发至订阅滞后时间(秒数)

overall\_latency     bigint                   \--总滞后秒数

);

createclustered index icx\_log\_publication on t\_log\_publication(writetime);

createprocedure p\_job\_monitor\_publication

begin

set nocount on

declare @dbname   varchar(50),

@procname varchar(100),

@token\_id int;

create table \#tmp\_job\_monitor\_publication(

distributor\_latency bigint,                  \-- 发布至分发滞后时间(秒数)

subscriber          varchar(200),            \-- 订阅服务器名称

subscriber\_db       varchar(200),            \-- 订阅数据库

subscriber\_latency  bigint,                  \-- 分发至订阅滞后时间(秒数)

overall\_latency     bigint                   \-- 总滞后秒数

);

\-- 获取最近小时内插入的跟踪的结果

declare t\_cur1 cursor for

select \[dbname\],token\_id  from t\_log\_publication with(nolock)

where writetime > dateadd(hour, \-2, getdate()) and distributor\_latency is null;

open t\_cur1;

fetch next from t\_cur1 into @dbname, @token\_id;

while (@@fetch\_status = 0)

begin

\-- 获取滞后时间

truncate table \#tmp\_job\_monitor\_publication;

set @procname = @dbname\+'.sys.sp\_helptracertokenhistory';

insert into \#tmp\_job\_monitor\_publication

execute @procname @publication=@dbname, @tracer\_id=@token\_id;

\-- 更新到日志中

update t\_log\_publication set distributor\_latency = b.distributor\_latency, subscriber\_latency = b.subscriber\_latency,

overall\_latency = b.overall\_latency

from t\_log\_publication a, \#tmp\_job\_monitor\_publication b

where a.token\_id = @token\_id and b.distributor\_latency is not null;

fetch next from t\_cur1 into @dbname, @token\_id;

end

close t\_cur1;

deallocate t\_cur1;

\-- 插入一个新的跟踪

declare t\_cur2 cursor for

select \[dbname\]  from t\_config\_publication with(nolock) where is\_enable > 0;

open t\_cur2;

fetch next from t\_cur2 into @dbname;

while (@@fetch\_status = 0)

begin

set @procname = @dbname\+'.sys.sp\_posttracertoken';

execute @procname @publication=@dbname, @tracer\_token\_id = @token\_id OUTPUT;

insert into t\_log\_publication(dbname, token\_id, writetime)

values(@dbname,@token\_id, getdate())

fetchnext from t\_cur2 into @dbname;

end

close t\_cur2;

deallocate t\_cur2;

\--删除天前过期的监控数据

delete from t\_log\_publication where writetime < dateadd(day, \-15, getdate());

set nocount off

end

[SQL Server]自动监控“发布订阅”的滞后时间(延迟时间)

发表评论取消回复

还没有评论，来说两句吧...

相关阅读

相关 SQL SERVER使用发布订阅同步数据库遇到的坑

相关 [SQL Server]自动监控“发布订阅”的滞后时间(延迟时间)

相关 SQL Server 2008 R2的发布订阅配置实践

相关 SQL SERVER 时间和日期函数

相关 sql server 2008 远程订阅发布

相关解决一个服务器时间滞后的问题

相关 SQL Server时间戳-并发 .

相关 sql server：sqlserver2008发布订阅同步

相关 SQL Server：查看sql语句的执行时间

相关 server sql的时间格式化