如何查看distirbution agent的执行进度

超、凢脫俗 2021-11-10 09:56 194阅读 0赞

在transactional replication troubleshooting的过程中，经常会遇到下面的场景：

客户在发布端执行了一个几百万行的更新，结果导致性能下降。 客户很想知道目前distribution agent的进度，完成的百分比，决定是等下去还是跳过这个过程。如果已经完成了90%，那么贸然停止就非常可惜了，并且rollback的操作也是要很长时间的。

下面介绍如何查看进度。

如果distribution agent已经启用了verbose log，可以通过verbose log来查看进度. Command id代表已经执行过的数量;transaction seqno表示正在进行的事务的xact\_seqno。 然后在distribution数据库执行selectcount(\*)From distribution..msrepl\_commands with(nolock)where xact\_seqno=@xact\_seqno.

对比结果就可以知道进度了。

![SouthEast][]

如果没有启用verbose log，就比较麻烦了，下面是具体的步骤。

1.  找到相应的distribution agent 名称和publisher\_database\_id 
    
    select\*From distribution..msdistribution\_agents 
    
    ![SouthEast 1][]
2.  通过名称就可以找到distribution agent进行的process id. 在distributor上执行下面的语句。
    
    select hostprocess from sys.sysprocesseswhere program\_name=@mergeAgentName
3.  同一个distribution agent进程的process id是相同的，所以可以通过这个process id(对应trace里的client process id)，使用sql server trace得到distribution agent正在subscriber端执行的语句. 
4.  假设我们得到了下面这个语句exec \[dbo\].\[sp\_MSupd\_dbota\] default,511,4,0x02 
5.  根据这个存储过程，我们可以得到相应的aritlce\_id。
    
    1.  在subscription database 执行sp\_helptext，得到表的名称
    2.  在distribution数据库查询得出article\_id. select article\_id from msarticles  where destination\_object=@tablename
6.  在subscriber上执行下面的语句,得到subscription数据库当前当xact\_seqno. （请将第一步得到的distribution name带入@distribution\_agent）
    
    select transaction\_timestamp,\*From MSreplication\_subscriptions where distribution\_agent=@distribution\_agent 
7.  接下来就可找到distribution agent当前正在执行的xact\_seqno了. 将第一步得到的publisher\_database\_id,第5步得到的article\_id和上一步得到的xact\_seqno带入下面的查询
    
    select xact\_seqno,count(\*)as number  From distribution..msrepl\_commands with(nolock)
    
    where publisher\_database\_id=**@publisher\_database\_id** and article\_id=**@article\_id**
    
    xact\_seqno>@xact\_**seqno** group by xact\_seqno orderby xact\_seqno 
8.  顺序靠前，并且number较大的就是正在执行的事务了。 您可能会问，为什么不是第六步得到的xact\_seqno的下一个呢(select min(xact\_seqno)From distribution..msrepl\_commands with(nolock)where publisher\_database\_id=@publisher\_database\_id and xact\_seqno>@xact\_seqno). 
    
    因为distribution 并不是每一个事务都单独提交的，而是根据CommitBatchSize  和CommitBatchThreshold来提交的，这样可以提高性能。 具体请参见http://www.kendalvandyke.com/2008/11/how-commitbatchsize-and.html
9.  在distribution数据执行sp\_browsereplcmds @xact\_seqno, @xact\_seqno 
    
    ![SouthEast 2][]
10. 用第四步得到的语句去查找，这样就可以知道当前执行到了什么位置

[SouthEast]: /images/20211109/2ce116a6992546689c33be897906e9ef.png
[SouthEast 1]: /images/20211109/399a20c6417a492eb4c53c125dfc99c6.png
[SouthEast 2]: /images/20211109/19a1960fe82042709a21531ec9444c47.png