powered by simpleCommunicator - 2.0.60     © 2026 Programmizd 02
Целевая тема:
Создать новую тему:
Автор:
Закрыть
Цитировать
Форумы / Microsoft SQL Server [игнор отключен] [закрыт для гостей] / Service broker для логирования, глюки
18 сообщений из 43, страница 2 из 2
Service broker для логирования, глюки
    #39748409
Кифирчик
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Участник
felix_ffКифирчик,
совокупность.

сделав овнером базы пользователя из группы сисадмин вы расширили его права, любой пользователь группы db_owner может сделать
execute as user = 'dbo' тем самым переключив себя на контекст 'sa' но он пока еще закрыт в базе.

поставив trustworthy вы открыли песочницу, тем самым пользователь теперь не заперт в базе а получает доступ прав уровня sysadmin
какую тогда "правильную" стратегию выбрать?
сделать отдельного пользователя не в группе db_owner и не sysadmin, и в собственники базы его?
...
Рейтинг: 0 / 0
Service broker для логирования, глюки
    #39748438
felix_ff
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Участник
Кифирчик,

я не знаю Вашей инфраструктуры. если у вас бизнес логика позволяет иметь овнером бд пользователя с наименьшими привилегиями, то желательно тогда овнером делать имено такого пользователя.

правильная стратегия если вам нужно использовать СБ между базами, это создание сертификатов и настройка безопасности на их основе.

тоже касаемо выдачи прав для пользоветей: давая какому то юзеру alter trace вы ему дали возможность создавать серверную трассировку. поэтому теперь этот логин может спокойно следить за запросами даже в тех базах в которые сам не отмаплен.
или поднапрячь сервак какой нибудь кошерной трассой на отлов lock:aсquired к примеру.ъ
в этом варианте лучше сделать процедуру обертку, и подписать ее сертификатом у которого овнер с нужным правом, а пользователю уже дать право на execute этой процедуры обертки.
...
Рейтинг: 0 / 0
Service broker для логирования, глюки
    #39748451
invm
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Участник
Кифирчик,

Может уже поделитесь, зачем понадобилось включать trustworthy?
...
Рейтинг: 0 / 0
Service broker для логирования, глюки
    #39748458
Кифирчик
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Участник
invmКифирчик,

Может уже поделитесь, зачем понадобилось включать trustworthy?
Да хз )
На моем компе все и без этого работает.
На объекте на одном сервере завелось, на другом нет. В трассировке еле откопал по поводу сообщение о нехватке прав (примерно).
Сравнил базы, отличие было в trustworthy.
Вспомнил что в одном из примеров по ServiceBroker мне попадалось что автор его включал.
Включил, пересоздал очередь и привязки - заработало.

Касаемо инфраструктуры
С MSSQL работает сервер приложения, под одним логином. Плюс соседнее приложение.
базы, примерно так
BASE_TASK1
BASE_TASK2
BASE_TASK3
BASE_LOG
Наш сервер приложений работает от user1, сторонний - от user2, у обоих во всех этих база db_datareader/writer, и grant exec.
Разделение на базы во много логическое, то есть имеются связи между базами. Сеть закрытая, IT отдел в сервера не лезет. Я бы сказал сертификаты тут избыточное усложнение, и усложнит жизнь коллегам.
И таких серверов несколько, между собой связаны репликациями.

в базах BASE_TASK1, BASE_TASK2б, BASE_TASK3 есть обертки над sp_trace_generateevent, примерно как в спойлере
Код: sql
1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
14.
15.
16.
17.
18.
19.
20.
21.
22.
23.
24.
25.
26.
create procedure log.spLogSimple 
     @logProc nvarchar(255)
   , @logMsg  nvarchar(255)
   , @logData nvarchar(2048) = null
as
begin
    --print 'call log.spLogSimple'
    declare @messageBody xml =
    (
         select
            @logProc as LogProc  
          , @logMsg  as LogMsg  
          , @logData as LogData  
          , db_name() as LogDb
          , getdate() as LogDateTime
        for xml raw  ('AsyncLogMessageSimple'), elements
    ) 
    --print cast(@messageBody as nvarchar(4000))

    -- передаем в событие
    declare @a nvarchar(128) = 'AsyncLogMessageSimple'
    declare @b varbinary(8000) = cast(@messageBody as varbinary(8000));
    exec sp_trace_generateevent 82, @a, @b;

    --print 'finish log.spLogSimple'
end



в базе BASE_LOG - очередь, сервис брокер и обработчик очереди, который вызывает ХП которая делает insert в BASE_LOG.log.AppLog
Код: sql
1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
14.
15.
16.
17.
18.
19.
20.
21.
22.
23.
24.
25.
26.
27.
28.
29.
30.
31.
32.
33.
34.
35.
36.
37.
38.
create procedure log.AsyncLogQueueProcessing with execute as owner
as
begin
    set nocount on;
    SET ARITHABORT OFF;
    set QUERY_GOVERNOR_COST_LIMIT 0;

    ...
    while (1=1)
    begin
        -- begin tran
        waitfor
        (
          receive top (1)
              @handle     = conversation_handle
            , @msgBody    = cast( message_body as xml)
            , @msgType   = message_type_name
          from AsyncLogQueue
        ), timeout 500;
 
        if (@@rowcount = 0)
        begin
            print '@@rowcount = 0, нет данных в очереди, выходим'           
            break;
        end
        ...
            exec log.XmlEventMessageProcessing @msgBody
 
    end
end
---------------
create procedure log.XmlEventMessageProcessing @message xml with execute as owner
as
begin
    ....
    insert into log.AppLog
    ....
end



подозреваю мои проблемы могу быть вызваны тем что я использовал with as owner
...
Рейтинг: 0 / 0
Service broker для логирования, глюки
    #39748535
felix_ff
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Участник
Кифирчик,

а вы с какой ошибкой то боролись включением trustworthy. на service broker он может повлиять только в том случае если у вас диалог межбазовых очередей.
...
Рейтинг: 0 / 0
Service broker для логирования, глюки
    #39748559
Кифирчик
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Участник
felix_ffКифирчик,
а вы с какой ошибкой то боролись включением trustworthy. на service broker он может повлиять только в том случае если у вас диалог межбазовых очередей.

Сейчас выключил на обеих базах, и без него все работает ((
...
Рейтинг: 0 / 0
Service broker для логирования, глюки
    #39748576
Кифирчик
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Участник
Ниже кусок кода как мне видится "правильно бы сделать"
собственником всех баз делам отличного пользователя, под которым не работают клиенты и который не может TRACE EVENT
в базах - два пользователя user_task, для работы клиентов, и user_log, у которого будут права на TRACE EVENT

user_task вызывает ХП обертки над TRACE EVENT которые run as user_log

но не работает - "Нет разрешения на запуск "SP_TRACE_GENERATEEVENT"

чего в коде не хватает?

Код: sql
1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
14.
15.
16.
17.
18.
19.
20.
21.
22.
23.
24.
25.
26.
27.
28.
29.
30.
31.
32.
33.
34.
35.
36.
37.
38.
39.
40.
41.
42.
43.
44.
45.
46.
47.
48.
49.
50.
51.
52.
53.
54.
55.
56.
57.
58.
59.
60.
61.
62.
63.
64.
65.
66.
67.
68.
69.
70.
71.
72.
73.
74.
75.
76.
77.
78.
79.
80.
81.
82.
83.
84.
85.
86.
87.
88.
89.
90.
91.
92.
93.
94.
95.
96.
97.
98.
99.
100.
101.
102.
103.
104.
105.
106.
107.
108.
109.
110.
111.
112.
113.
114.
115.
116.
117.
118.
119.
120.
121.
122.
123.
124.
125.
126.
127.
128.
129.
130.
131.
132.
133.
134.
135.
136.
137.
138.
139.
140.
141.
142.
143.
144.
145.
146.
147.
148.
149.
150.
151.
152.
153.
154.
155.
156.
157.
158.
159.
160.
161.
162.
163.
164.
165.
166.
167.
168.
169.
170.
171.
172.
173.
174.
175.
176.
177.
178.
179.
180.
181.
182.
183.
184.
185.
186.
187.
188.
189.
190.
191.
192.
193.
194.
195.
196.
197.
198.
199.
200.
201.
202.
203.
204.
205.
206.
207.
208.
209.
210.
211.
212.
213.
214.
215.
216.
217.
218.
219.
220.
221.
222.
223.
224.
225.
226.
227.
228.
229.
230.
231.
232.
233.
234.
235.
236.
237.
238.
239.
240.
241.
242.
243.
244.
245.
246.
247.
248.
249.
250.
251.
252.
253.
254.
255.
256.
257.
258.
259.
260.
261.
262.
263.
264.
265.
266.
267.
268.
269.
270.
271.
use master
go
if exists (select 1 from sys.databases where name='db_log')
    drop database db_log

if exists (select 1 from sys.databases where name='db_task')
    drop database db_task

go


if exists (select 1 from master.sys.server_principals where name = 'login_db_owner')
    drop login login_db_owner
go

if exists (select * from master.sys.server_principals where name = 'login_task')
    drop login login_task
go

if exists (select * from master.sys.server_principals where name = 'login_log')
    drop login login_log
go



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

create database db_log
go
create database db_task
go

create login login_db_owner with password = 'login_db_owner'
go
create login login_task with password = 'login_task'
go
create login login_log with password = 'login_log'
go

-- собственник баз - login_db_owner

alter authorization on database::db_log to login_db_owner
go
alter authorization on database::db_task to login_db_owner
go


-- логину login_log даем возможность вызывать EVENT-ы
use master
go
grant alter trace to login_log
go

-----------------
-- пользователи в базах
use db_task
go

create user user_task for login login_task
create user user_log for login login_log
go

alter role db_datareader add member user_task
alter role db_datawriter add member user_task
go
grant exec to user_task
grant exec to user_log
go
-----------------
use db_log
go

create user user_task for login login_task
create user user_log for login login_log
go

alter role db_datareader add member user_log
go
alter role db_datawriter add member user_log
go
grant exec to user_log
go
--------------------------
-- тестовая ХП бизнес логики и обертка над sp_trace_generateevent
use db_task
go
create schema log
go
go
-- вроде как логину login_log (c которым связан пользователь базы user_log) 
-- даны права на sp_trace_generateevent
-- и от его имени запустим ХП
create procedure log.spLogSimple @logMsg  nvarchar(255), @logData nvarchar(2048) = null with execute as 'user_log'
as
begin
    declare @m xml= (select @logMsg  as LogMsg , @logData as LogData for xml raw  ('AsyncLogMessageSimple'), elements) 
    declare @a nvarchar(128) = 'AsyncLogMessageSimple'
    declare @b varbinary(8000) = cast(@m as varbinary(8000));
    exec sp_trace_generateevent 82, @a, @b;
end
go
create procedure SomeTaskProc as
begin
    exec log.spLogSimple 'SomeTaskProc start', 'args1'
    waitfor delay '00:00:01.000'
    exec log.spLogSimple 'SomeTaskProc finish', 'args2'
end
go

--------------
-- база с логами
use db_log
go
create schema log
go
create table log.AppLog(LogDateTime datetime, LogMsg nvarchar(128), LogData nvarchar(2000), Stamp timestamp)
go

go
create procedure log.XmlMsgProcessing @message xml
as
begin

    declare @postTime   datetime        = @message.value('(EVENT_INSTANCE/PostTime)[1]'  , 'datetime'       )
    declare @textData   nvarchar(128)   = @message.value('(EVENT_INSTANCE/TextData)[1]'  , 'sysname'        )
    declare @binaryData varbinary(8000) = @message.value('(EVENT_INSTANCE/BinaryData)[1]', 'varbinary(8000)')

    declare @messageXml xml = cast(cast(@binaryData as nvarchar(4000)) as xml)

    declare @logMsg  nvarchar(128) = @messageXml.value('(AsyncLogMessageSimple/LogMsg)[1]' ,'nvarchar(128)'  )
    declare @logData nvarchar(128) = @messageXml.value('(AsyncLogMessageSimple/LogData)[1]','nvarchar(2000)'  )

    insert into log.AppLog(LogDateTime, LogMsg, LogData)
    select @postTime, @logMsg, @logData
end
go

create procedure log.AsyncLogQueueProcessing with execute as 'user_log'
as
begin

    set nocount on;
    set arithabort off;
    set query_governor_cost_limit 0;

    declare @h uniqueidentifier, @h2 uniqueidentifier, @m xml, @msgType sysname 

    while 1=1 begin
         waitfor (receive top (1) @h = conversation_handle, @m = message_body from log.AsyncLogQueue), timeout 500

         if @@rowcount = 0 begin 
              if @h is not null end conversation @h;
              break;
         end

         --логика обработки сообщения
         if @msgType = N'http://schemas.microsoft.com/SQL/Notifications/EventNotification'
         begin
             exec log.XmlMsgProcessing @m
             end conversation @h with cleanup;
         end
         else if @msgType = N'http://schemas.microsoft.com/SQL/ServiceBroker/EndDialog'
             end conversation @h with cleanup;
         else if @msgType = N'http://schemas.microsoft.com/SQL/ServiceBroker/Error'
             end conversation @h with cleanup;
     
         if @h2 <> @h and @h2 is not null end conversation @h2;

         set @h2 = @h;
    end

    -- declare @handle uniqueidentifier;
    -- declare @msgBody xml;
    -- declare @msgBodyStr nvarchar(max);
    -- declare @msgType sysname;
    -- while (1=1)
    -- begin        
    --     waitfor(
    --       receive top (1)
    --           @handle  = conversation_handle
    --         , @msgBody = cast( message_body as xml)
    --         , @msgType = message_type_name
    --       from AsyncLogQueue
    --     ), timeout 500;
    -- 
    --     if (@@rowcount = 0)
    --     begin
    --         print '@@rowcount = 0, нет данных в очереди, выходим'
    --         break;
    --     end
    --      
    --     if @msgType = N'http://schemas.microsoft.com/SQL/Notifications/EventNotification'
    --     begin
    --         exec log.XmlEventMessageProcessing @msgBody
    --         end conversation @handle with cleanup;
    --     end
    --     else if @msgType = N'http://schemas.microsoft.com/SQL/ServiceBroker/EndDialog'
    --         end conversation @handle with cleanup;
    --     else if @msgType = N'http://schemas.microsoft.com/SQL/ServiceBroker/Error'
    --         end conversation @handle with cleanup;
    -- 
    -- end
end
go

create queue log.AsyncLogQueue with status = on, retention = off,
 activation (status = on, procedure_name = log.AsyncLogQueueProcessing, max_queue_readers = 5, execute as 'user_log'),
 poison_message_handling (status = on);
go

go
create service AsyncLogService authorization user_log on queue log.AsyncLogQueue ([http://schemas.microsoft.com/SQL/Notifications/PostEventNotification] );
go

drop event notification AsyncLogEventNotify on server
go
create event notification AsyncLogEventNotify on server for USERCONFIGURABLE_0 
    to service 'AsyncLogService', 'current database';
go
---------------------------------------------------------
---------------------------------------------------------
use db_task
go
-- эмитируем вызов хранимки бизнес логики от пользователя user_task
execute as user = 'user_task'

    begin try
        exec SomeTaskProc
    end try
    begin catch
        print 'Error in SomeTaskProc'
        print '@error_procedure = '+  isnull(                error_procedure() ,'null')
        print '@error_line      = '+  isnull(convert(varchar,error_line     ()),'null')
        print '@error_number    = '+  isnull(convert(varchar,error_number   ()),'null')
        print '@error_message   = '+  isnull(                error_message  () ,'null')
        print '@error_severity  = '+  isnull(convert(varchar,error_severity ()),'null')
        print '@error_state     = '+  isnull(convert(varchar,error_state    ()),'null')
    end catch

revert

---------------------------------------------------------
---------------------------------------------------------
use db_log
go
-- пробуем вставить сообщение под user_log и прочитать его
--execute as user = 'login_log'
execute as user = 'user_log'

    begin try
        -- exec db_task.log.spLogSimple 'Test message','some data'

        declare @m xml= (select 'Test message2'  as LogMsg , 'some data2' as LogData for xml raw  ('AsyncLogMessageSimple'), elements) 
        declare @a nvarchar(128) = 'AsyncLogMessageSimple'
        declare @b varbinary(8000) = cast(@m as varbinary(8000));
        exec sp_trace_generateevent 82, @a, @b;

        exec log.AsyncLogQueueProcessing
        select top 20 * from log.AppLog order by Stamp desc
    end try
    begin catch
        print 'Error in db_log'
        print '@error_procedure = '+  isnull(                error_procedure() ,'null')
        print '@error_line      = '+  isnull(convert(varchar,error_line     ()),'null')
        print '@error_number    = '+  isnull(convert(varchar,error_number   ()),'null')
        print '@error_message   = '+  isnull(                error_message  () ,'null')
        print '@error_severity  = '+  isnull(convert(varchar,error_severity ()),'null')
        print '@error_state     = '+  isnull(convert(varchar,error_state    ()),'null')
    end catch

revert

...
Рейтинг: 0 / 0
Service broker для логирования, глюки
    #39748621
felix_ff
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Участник
Кифирчик,

вы путаете контекст переключения, в вашем случае надо использовать execute as login вместо execute as user

сделайте
Код: sql
1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
14.
15.
16.
17.
18.
19.
20.
21.
22.
23.
24.
25.
26.
27.
use db_log
go

execute as user = 'user_log';
go
use master
select * from sys.user_token
select * from sys.login_token;
go

use db_log
go
revert;
go

execute as login = 'login_log';
go
use master
go
select * from sys.user_token
select * from sys.login_token;
go

use db_log
go
revert;
go

увидите разницу
...
Рейтинг: 0 / 0
Service broker для логирования, глюки
    #39748626
felix_ff
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Участник
о внимательней посмотрел, там у вас намешано.

легче сделать так:

Код: sql
1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
14.
15.
16.
17.
18.
19.
20.
21.
22.
23.
24.
25.
26.
27.
28.
29.
30.
31.
32.
33.
34.
35.
36.
use master
go
create certificate [trace_cert] ENCRYPTION BY PASSWORD = 'some_strong_password' WITH SUBJECT = 'certificate_for_trace_events';
create login [trace_login] from certificate [trace_cert];

BACKUP CERTIFICATE [trace_cert] TO FILE = 'C:\temp\trace_cert.cer'  
     WITH PRIVATE KEY   
      (   
        FILE = 'C:\temp\trace_cert.pvk' ,  
        ENCRYPTION BY PASSWORD = 'storng_password'   
        ,DECRYPTION BY PASSWORD = 'storng_password'   
      );

grant alter trace to [trace_login];
go

use db_task
go

create certificate [trace_cert] from file = 'C:\temp\trace_cert.cer' with private key (FILE = 'C:\temp\trace_cert.pvk' ,  
        ENCRYPTION BY PASSWORD = 'storng_password'   
        ,DECRYPTION BY PASSWORD = 'storng_password');
go

create or alter procedure log.spLogSimple @logMsg  nvarchar(255), @logData nvarchar(2048) = null --with execute as 'user_log'
as
begin
    declare @m xml= (select @logMsg  as LogMsg , @logData as LogData for xml raw  ('AsyncLogMessageSimple'), elements) 
    declare @a nvarchar(128) = 'AsyncLogMessageSimple'
    declare @b varbinary(8000) = cast(@m as varbinary(8000));
    exec sp_trace_generateevent 82, @a, @b;
end
go

add signature to [spLogSimple] by certificate [trace_cert] with password = 'strong_password';
go



тогда вам не надо парится с переключением контекстов и их правами.
у вас права выданные логину trace_login будут применены на вызов модуля который подписан соответствующим сертификатом.

писал по памяти может где то с синтаксисом накосячил.
...
Рейтинг: 0 / 0
Service broker для логирования, глюки
    #39748834
Кифирчик
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Участник
felix_ff, Сработало )
На память получилось очень точно )))

Понятно, то есть нельзя просто так сказать "выполни от этого логина", он должен как то "логиниться", и это возможно автоматически если создать логин с сертификатом.
Код: sql
1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
14.
15.
16.
17.
18.
19.
20.
21.
22.
23.
24.
25.
26.
27.
28.
29.
30.
31.
32.
33.
34.
35.
36.
37.
38.
39.
40.
41.
42.
43.
44.
45.
46.
47.
48.
49.
50.
51.
52.
53.
54.
55.
56.
57.
58.
59.
60.
61.
62.
63.
64.
65.
66.
67.
68.
69.
70.
71.
72.
73.
74.
75.
76.
77.
78.
79.
80.
81.
82.
83.
84.
85.
86.
87.
88.
89.
90.
91.
92.
93.
94.
95.
96.
97.
98.
99.
100.
101.
102.
103.
104.
105.
106.
107.
108.
109.
110.
111.
112.
113.
114.
115.
116.
117.
118.
119.
use master
go
if exists (select 1 from sys.databases where name='db_task')
    drop database db_task

go

if exists (select 1 from master.sys.server_principals where name = 'login_db_owner')
    drop login login_db_owner
go

if exists (select * from master.sys.server_principals where name = 'login_task')
    drop login login_task
go

if exists (select * from master.sys.server_principals where name = 'login_trace')
    drop login login_trace
go
use master
go

-------------------------------------------------------------------
create database db_task
go

create login login_db_owner with password = 'login_db_owner'
go
create login login_task with password = 'login_task'
go

---------------------------------------------------------------
-- СЕРТИФИКАТ
-- drop certificate [trace_cert]

-- create certificate [trace_cert] encryption by password = 'some_strong_password' with subject = 'certificate_for_trace_events';

-- backup certificate [trace_cert] to file = 'c:\svn\trace_cert.cer'  with private key   
--  ( file = 'c:\svn\trace_cert.pvk',encryption by password = 'some_strong_password', decryption by password = 'some_strong_password' );

create login login_trace from certificate [trace_cert];
go
use master
go
grant alter trace to login_trace;
go
---------------------------------------------------------------

-- собственник баз - login_db_owner
alter authorization on database::db_task to login_db_owner
go

-----------------
-- пользователи в базах
use db_task
go

create user user_task for login login_task
go

alter role db_datareader add member user_task
alter role db_datawriter add member user_task
go
grant exec to user_task
go

--------------------------
-- тестовая ХП бизнес логики и обертка над sp_trace_generateevent
use db_task
go
create schema log
go

create certificate [trace_cert] from file = 'c:\svn\trace_cert.cer' with private key (file = 'c:\svn\trace_cert.pvk' ,  
        encryption by password = 'some_strong_password'   
        ,decryption by password = 'some_strong_password');

go
create procedure log.spLogSimple @logMsg  nvarchar(255), @logData nvarchar(2048) = null -- with execute as 'user_log'
as
begin
    declare @m xml= (select @logMsg  as LogMsg , @logData as LogData for xml raw  ('AsyncLogMessageSimple'), elements) 
    declare @a nvarchar(128) = 'AsyncLogMessageSimple'
    declare @b varbinary(8000) = cast(@m as varbinary(8000));
    exec sp_trace_generateevent 82, @a, @b;
end
go
add signature to log.spLogSimple by certificate [trace_cert] with password = 'some_strong_password';
go
go
create procedure SomeTaskProc as
begin
    exec log.spLogSimple 'SomeTaskProc start', 'args1'
    waitfor delay '00:00:01.000'
    exec log.spLogSimple 'SomeTaskProc finish', 'args2'
end
go

---------------------------------------------------------
use db_task
go
-- эмитируем вызов хранимки бизнес логики от логина login_task
execute as login = 'login_task'

    begin try
        print 'Current login/user: ['+isnull(SUSER_NAME(), 'null')+']/['+isnull(current_user, 'null')+'], call SomeTaskProc...'
        exec SomeTaskProc
        print 'Ok'
    end try
    begin catch
        print 'Error in SomeTaskProc'
        print '@error_procedure = '+  isnull(                error_procedure() ,'null')
        print '@error_line      = '+  isnull(convert(varchar,error_line     ()),'null')
        print '@error_number    = '+  isnull(convert(varchar,error_number   ()),'null')
        print '@error_message   = '+  isnull(                error_message  () ,'null')
        print '@error_severity  = '+  isnull(convert(varchar,error_severity ()),'null')
        print '@error_state     = '+  isnull(convert(varchar,error_state    ()),'null')
    end catch

revert


Осталось срастить очередями, понять что-там с диалогами точно происходит и натянуть свои более сложные обработчики.

Единственное, НО, решение в итоге получается не такое уж и тривиальное, если через год за базу возьмутся менее опытные коллеги, что-то сломается, может получиться что им будет проще свой велосипед чем это отремонтировать.

И есть вопросы как это будет себя вести с бэкапами и переносом баз.
Сертификат как я понимаю живет в сервере, если я переношу базу на другой сервер - то там нужно сертификат "подгружать"и обновлять add signature to log.spLogSimple? или делать новый сертификат и переподписывать log.spLogSimple?
...
Рейтинг: 0 / 0
Service broker для логирования, глюки
    #39748839
invm
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Участник
КифирчикПонятно, то есть нельзя просто так сказать "выполни от этого логина", он должен как то "логиниться", и это возможно автоматически если создать логин с сертификатом. https://docs.microsoft.com/ru-ru/previous-versions/sql/sql-server-2008-r2/ms188304(v=sql.105)
КифирчикСертификат как я понимаю живет в сервереСертификат живет в той БД, где был создан.
...
Рейтинг: 0 / 0
Service broker для логирования, глюки
    #39749732
Кифирчик
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Участник
Еще одна паталогия.
Столбец слева - это время вызова eventa, берется перед самим вызовом, то есть реальное время сработки вызова в ХП.
Столбец справа - это временная метка записи в таблицу с логами, то есть порядок обработки сообщений (desc).

Код: plaintext
1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
LogDatetime              Stamp
2018-12-18 16:48:19.507  0x00000000000B8C0F
2018-12-18 16:48:04.230  0x00000000000B8C0E
2018-12-18 16:48:35.720  0x00000000000B8C0D
2018-12-18 16:48:19.563  0x00000000000B8C0C
2018-12-18 16:48:35.700  0x00000000000B8C0B
2018-12-18 16:48:35.687  0x00000000000B8C08
2018-12-18 16:48:35.683  0x00000000000B8C07
2018-12-18 16:48:35.493  0x00000000000B8C06
2018-12-18 16:48:35.490  0x00000000000B8C05
2018-12-18 16:48:35.490  0x00000000000B8C04
2018-12-18 16:48:19.357  0x00000000000B8C03
2018-12-18 16:48:11.397  0x00000000000B8C02

Предполагалось что Stamp сможет определить верный порядок вызовов Event, но в столбце LogDateTime данные вперемешку.
В инструкции к RECEIVE сказано - "Результирующий набор, возвращенный инструкцией RECEIVE, неявно упорядочен."
То есть очередь как получила, так и выдает (видимо в обратном порядке, order by к очереди не применимо).

Получается event-ы доходят в очередь не всегда в порядке их вызова?
...
Рейтинг: 0 / 0
Service broker для логирования, глюки
    #39749760
felix_ff
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Участник
Кифирчик,

именно, очередь сообщений гарантируется только в рамках одного диалога, а не кучи диалогов.
...
Рейтинг: 0 / 0
Service broker для логирования, глюки
    #39749886
Кифирчик
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Участник
Мде...
еще два вопроса:
1) conversation, диалог, относительно Notify event, где его рамки? вызов одной ХП? или пакета?
2) можно ли сделать так чтоб сами notify event и сообщения типа "The activated proc '[log].[AsyncLogQueueProcessing]' running on queue 'VTSDB2_LOG.log.AsyncLogQueue' output the following: 'exec spLogSimpleDo1'" не валились в журнал MSSQL? это как-нибудь настраивается?
...
Рейтинг: 0 / 0
Service broker для логирования, глюки
    #39749907
felix_ff
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Участник
КифирчикМде...
еще два вопроса:
1) conversation, диалог, относительно Notify event, где его рамки? вызов одной ХП? или пакета?
2) можно ли сделать так чтоб сами notify event и сообщения типа "The activated proc '[log].[AsyncLogQueueProcessing]' running on queue 'VTSDB2_LOG.log.AsyncLogQueue' output the following: 'exec spLogSimpleDo1'" не валились в журнал MSSQL? это как-нибудь настраивается?

1) не совсем понятен вопрос. вы имеете ввиду до какого момента сообщения будут валиться в один и тот же диалог?
если вопрос в этом то точно не подскажу, надо экспериментировать. вообще в рамках одного уведомления должен быть один диалог, но я встречал ситуации когда это не так. что бы сообщения не копились мы писали задание которое раз в неделю пересоздавало уведомление.

2) у вас сообщения в журнал могут сыпаться если у вас уведомление о событии не получается доставить. что детально в сообщении лога написано?
...
Рейтинг: 0 / 0
Service broker для логирования, глюки
    #39749965
invm
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Участник
Кифирчикconversation, диалог, относительно Notify event, где его рамки? вызов одной ХП? или пакета?Вас это вообще не должно волновать. Отметка времени должна приходить вместе с логируемым сообщением. Не следует привязываться к порядку поступления сообщений и, тем более, к порядку строк в таблице логов.
Не нужно завершать диалог на каждый чих. Не вы этот диалог начали - не вам и завершать.
Завершать нужно лишь в ответ на EndDialog и Error и без опции with cleanup (мой косяк в примере). Данная опция служит для аварийного завершения.
И проверьте что твориться в sys.conversation_endpoints в msdb и VTSDB2_LOG.
Кифирчикможно ли сделать так чтоб сами notify event и сообщения типа "The activated proc '[log].[AsyncLogQueueProcessing]' running on queue 'VTSDB2_LOG.log.AsyncLogQueue' output the following: 'exec spLogSimpleDo1'" не валились в журнал MSSQL? это как-нибудь настраивается?Уберите весь диагностический вывод из процедуры log.AsyncLogQueue.
...
Рейтинг: 0 / 0
Service broker для логирования, глюки
    #39750250
Кифирчик
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Участник
Блин, точно
"The activated proc '[log].[AsyncLogQueueProcessing]' running on queue 'VTSDB2_LOG.log.AsyncLogQueue' output the following: 'exec spLogSimpleDo1'
это PRINT 'exec spLogSimpleDo1' внутри AsyncLogQueueProcessing

invmВас это вообще не должно волновать. Отметка времени должна приходить вместе с логируемым сообщением. Не следует привязываться к порядку поступления сообщений и, тем более, к порядку строк в таблице логов.
К сожалению отметки времени не уникальны, могут приходить две (и даже 5) одинаковые, и тогда проблематично понять в какой последовательности они появились. Если диалог в очереди имеет границы например в рамках одного @spid, или внутри одной ХП - то это позволило бы точно сохранить порядок вызовов, исходя из порядка появления сообщений в очереди.
Иначе - нужно формировать Stamp перед отправкой логируемого сообщения. Или последовательность длинючую использовать.

Нужно и правда сделать эксперимент, сохраняя в обработчике очереди handle диалога. Мало ли, мне бы это много упростило )

sys.conversation_endpoints
LOG
Код: plaintext
1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
conversation_handle	conversation_id	is_initiator	service_contract_id	conversation_group_id	service_id	lifetime	state	state_desc	far_service	far_broker_instance	principal_id	far_principal_id	outbound_session_key_identifier	inbound_session_key_identifier	security_timestamp	dialog_timer	send_sequence	last_send_tran_id	end_dialog_sequence	receive_sequence	receive_sequence_frag	system_sequence	first_out_of_order_sequence	last_out_of_order_sequence	last_out_of_order_frag	is_system	priority
B7B2F36D-72FF-E811-8127-0CC47A70A1C0	A08BFD0B-64C5-4B63-A087-B8E7B9A8F976	0	2	00000000-0000-0000-0000-000000000000	65561	2087-01-01 10:44:50.107	CD	CLOSED	 http://schemas.microsoft.com/SQL/Notifications/EventNotificationService 	E6F81215-B045-463F-BF31-96D7359B35B4	1	1	00000000-0000-0000-0000-000000000000	00000000-0000-0000-0000-000000000000	1900-01-01 00:00:00.000	1900-01-01 00:00:00.000	0	0x000000000000	-1	11	0	0	-1	0	0	0	5
DEA109ED-95FF-E811-8127-0CC47A70A1C0	172476B0-6464-4DB9-A6CA-434B14087F3F	0	2	00000000-0000-0000-0000-000000000000	65561	2087-01-01 10:44:50.107	CD	CLOSED	 http://schemas.microsoft.com/SQL/Notifications/EventNotificationService 	E6F81215-B045-463F-BF31-96D7359B35B4	1	1	00000000-0000-0000-0000-000000000000	00000000-0000-0000-0000-000000000000	1900-01-01 00:00:00.000	1900-01-01 00:00:00.000	0	0x000000000000	-1	8	0	0	-1	0	0	0	5
D64E0EF4-A8FF-E811-8127-0CC47A70A1C0	A3A3467B-5E23-4942-A844-827CA59B7B93	0	2	00000000-0000-0000-0000-000000000000	65561	2087-01-01 10:44:50.107	CD	CLOSED	 http://schemas.microsoft.com/SQL/Notifications/EventNotificationService 	E6F81215-B045-463F-BF31-96D7359B35B4	1	1	00000000-0000-0000-0000-000000000000	00000000-0000-0000-0000-000000000000	1900-01-01 00:00:00.000	1900-01-01 00:00:00.000	0	0x000000000000	-1	4	0	0	-1	0	0	0	5
8C5D3F74-B0FF-E811-8127-0CC47A70A1C0	59930D03-6E20-4EB1-A76E-4C4C554A11D7	0	2	8B5D3F74-B0FF-E811-8127-0CC47A70A1C0	65562	2087-01-01 18:10:44.443	CO	CONVERSING	 http://schemas.microsoft.com/SQL/Notifications/EventNotificationService 	E6F81215-B045-463F-BF31-96D7359B35B4	1	1	00000000-0000-0000-0000-000000000000	00000000-0000-0000-0000-000000000000	1900-01-01 00:00:00.000	1900-01-01 00:00:00.000	0	0x000000000000	-1	270110	0	0	-1	0	0	0	5
65D5176F-4500-E911-8127-0CC47A70A1C0	337D1522-475E-4F85-B91D-CF9AA493DF0E	0	2	64D5176F-4500-E911-8127-0CC47A70A1C0	65562	2087-01-01 18:10:44.440	CO	CONVERSING	 http://schemas.microsoft.com/SQL/Notifications/EventNotificationService 	E6F81215-B045-463F-BF31-96D7359B35B4	1	1	00000000-0000-0000-0000-000000000000	00000000-0000-0000-0000-000000000000	1900-01-01 00:00:00.000	1900-01-01 00:00:00.000	0	0x000000000000	-1	35229	0	0	-1	0	0	0	5
D686F8A0-FD00-E911-8127-0CC47A70A1C0	ACF3043A-465D-44BE-81BB-AEF2F3A098AA	0	2	D586F8A0-FD00-E911-8127-0CC47A70A1C0	65562	2087-01-01 18:10:44.440	CO	CONVERSING	 http://schemas.microsoft.com/SQL/Notifications/EventNotificationService 	E6F81215-B045-463F-BF31-96D7359B35B4	1	1	00000000-0000-0000-0000-000000000000	00000000-0000-0000-0000-000000000000	1900-01-01 00:00:00.000	1900-01-01 00:00:00.000	0	0x000000000000	-1	49503	0	0	-1	0	0	0	5
548A006E-1701-E911-8127-0CC47A70A1C0	1E5D472B-A2AB-46BF-9B1E-D2809A0B6054	0	2	538A006E-1701-E911-8127-0CC47A70A1C0	65562	2087-01-01 18:10:44.443	CO	CONVERSING	 http://schemas.microsoft.com/SQL/Notifications/EventNotificationService 	E6F81215-B045-463F-BF31-96D7359B35B4	1	1	00000000-0000-0000-0000-000000000000	00000000-0000-0000-0000-000000000000	1900-01-01 00:00:00.000	1900-01-01 00:00:00.000	0	0x000000000000	-1	56359	0	0	-1	0	0	0	5
53C289A0-2C01-E911-8127-0CC47A70A1C0	F7773E74-D6F1-44F1-9DC6-8CC624698FA7	0	2	52C289A0-2C01-E911-8127-0CC47A70A1C0	65562	2087-01-01 18:10:44.440	CO	CONVERSING	 http://schemas.microsoft.com/SQL/Notifications/EventNotificationService 	E6F81215-B045-463F-BF31-96D7359B35B4	1	1	00000000-0000-0000-0000-000000000000	00000000-0000-0000-0000-000000000000	1900-01-01 00:00:00.000	1900-01-01 00:00:00.000	0	0x000000000000	-1	51491	0	0	-1	0	0	0	5
D8AC24B0-3001-E911-8127-0CC47A70A1C0	F548C0BF-B19B-490F-A136-E147B2C018F6	0	2	D7AC24B0-3001-E911-8127-0CC47A70A1C0	65562	2087-01-01 18:10:44.440	CO	CONVERSING	 http://schemas.microsoft.com/SQL/Notifications/EventNotificationService 	E6F81215-B045-463F-BF31-96D7359B35B4	1	1	00000000-0000-0000-0000-000000000000	00000000-0000-0000-0000-000000000000	1900-01-01 00:00:00.000	1900-01-01 00:00:00.000	0	0x000000000000	-1	76844	0	0	-1	0	0	0	5
4BB85015-3801-E911-8127-0CC47A70A1C0	B23C5BD4-2E68-49D8-8CDB-BD8DC2C0DD05	0	2	4AB85015-3801-E911-8127-0CC47A70A1C0	65562	2087-01-01 18:10:44.440	CO	CONVERSING	 http://schemas.microsoft.com/SQL/Notifications/EventNotificationService 	E6F81215-B045-463F-BF31-96D7359B35B4	1	1	00000000-0000-0000-0000-000000000000	00000000-0000-0000-0000-000000000000	1900-01-01 00:00:00.000	1900-01-01 00:00:00.000	0	0x000000000000	-1	59348	0	0	-1	0	0	0	5
7A4EEBD8-4801-E911-8127-0CC47A70A1C0	CF68993D-DEEB-4C19-8A99-1343EEF5661B	0	2	794EEBD8-4801-E911-8127-0CC47A70A1C0	65562	2087-01-01 18:10:44.440	CO	CONVERSING	 http://schemas.microsoft.com/SQL/Notifications/EventNotificationService 	E6F81215-B045-463F-BF31-96D7359B35B4	1	1	00000000-0000-0000-0000-000000000000	00000000-0000-0000-0000-000000000000	1900-01-01 00:00:00.000	1900-01-01 00:00:00.000	0	0x000000000000	-1	47554	0	0	-1	0	0	0	5

msdb
Код: plaintext
1.
2.
3.
4.
5.
6.
7.
8.
9.
conversation_handle	conversation_id	is_initiator	service_contract_id	conversation_group_id	service_id	lifetime	state	state_desc	far_service	far_broker_instance	principal_id	far_principal_id	outbound_session_key_identifier	inbound_session_key_identifier	security_timestamp	dialog_timer	send_sequence	last_send_tran_id	end_dialog_sequence	receive_sequence	receive_sequence_frag	system_sequence	first_out_of_order_sequence	last_out_of_order_sequence	last_out_of_order_frag	is_system	priority
9DC46B29-72FF-E811-8127-0CC47A70A1C0	FFFB9CA6-2C5D-4CA1-BFCE-2BEC0ACE3B98	1	2	00000000-0000-0000-0000-000000000000	2	2087-01-01 10:44:50.107	DO	DISCONNECTED_OUTBOUND	AsyncLogService	D775EE0B-292D-4712-AECB-89C4559A6ED8	4	-1	00000000-0000-0000-0000-000000000000	00000000-0000-0000-0000-000000000000	1900-01-01 00:00:00.000	1900-01-01 00:00:00.000	4603	0x625CED000000	4603	0	0	0	-1	0	0	1	5
745D3F74-B0FF-E811-8127-0CC47A70A1C0	F548C0BF-B19B-490F-A136-E147B2C018F6	1	2	755D3F74-B0FF-E811-8127-0CC47A70A1C0	2	2087-01-01 18:10:44.440	CO	CONVERSING	AsyncLogService	D775EE0B-292D-4712-AECB-89C4559A6ED8	4	-1	00000000-0000-0000-0000-000000000000	00000000-0000-0000-0000-000000000000	1900-01-01 00:00:00.000	1900-01-01 00:00:00.000	76844	0x2A20EF000000	-1	0	0	0	-1	0	0	1	5
775D3F74-B0FF-E811-8127-0CC47A70A1C0	ACF3043A-465D-44BE-81BB-AEF2F3A098AA	1	2	785D3F74-B0FF-E811-8127-0CC47A70A1C0	2	2087-01-01 18:10:44.440	CO	CONVERSING	AsyncLogService	D775EE0B-292D-4712-AECB-89C4559A6ED8	4	-1	00000000-0000-0000-0000-000000000000	00000000-0000-0000-0000-000000000000	1900-01-01 00:00:00.000	1900-01-01 00:00:00.000	49503	0xD81EEF000000	-1	0	0	0	-1	0	0	1	5
7A5D3F74-B0FF-E811-8127-0CC47A70A1C0	B23C5BD4-2E68-49D8-8CDB-BD8DC2C0DD05	1	2	7B5D3F74-B0FF-E811-8127-0CC47A70A1C0	2	2087-01-01 18:10:44.440	CO	CONVERSING	AsyncLogService	D775EE0B-292D-4712-AECB-89C4559A6ED8	4	-1	00000000-0000-0000-0000-000000000000	00000000-0000-0000-0000-000000000000	1900-01-01 00:00:00.000	1900-01-01 00:00:00.000	59348	0x5A21EF000000	-1	0	0	0	-1	0	0	1	5
7D5D3F74-B0FF-E811-8127-0CC47A70A1C0	F7773E74-D6F1-44F1-9DC6-8CC624698FA7	1	2	7E5D3F74-B0FF-E811-8127-0CC47A70A1C0	2	2087-01-01 18:10:44.440	CO	CONVERSING	AsyncLogService	D775EE0B-292D-4712-AECB-89C4559A6ED8	4	-1	00000000-0000-0000-0000-000000000000	00000000-0000-0000-0000-000000000000	1900-01-01 00:00:00.000	1900-01-01 00:00:00.000	51491	0x5D1FEF000000	-1	0	0	0	-1	0	0	1	5
805D3F74-B0FF-E811-8127-0CC47A70A1C0	337D1522-475E-4F85-B91D-CF9AA493DF0E	1	2	815D3F74-B0FF-E811-8127-0CC47A70A1C0	2	2087-01-01 18:10:44.440	CO	CONVERSING	AsyncLogService	D775EE0B-292D-4712-AECB-89C4559A6ED8	4	-1	00000000-0000-0000-0000-000000000000	00000000-0000-0000-0000-000000000000	1900-01-01 00:00:00.000	1900-01-01 00:00:00.000	35229	0x821FEF000000	-1	0	0	0	-1	0	0	1	5
835D3F74-B0FF-E811-8127-0CC47A70A1C0	CF68993D-DEEB-4C19-8A99-1343EEF5661B	1	2	845D3F74-B0FF-E811-8127-0CC47A70A1C0	2	2087-01-01 18:10:44.440	CO	CONVERSING	AsyncLogService	D775EE0B-292D-4712-AECB-89C4559A6ED8	4	-1	00000000-0000-0000-0000-000000000000	00000000-0000-0000-0000-000000000000	1900-01-01 00:00:00.000	1900-01-01 00:00:00.000	47554	0x1EF7EE000000	-1	0	0	0	-1	0	0	1	5
865D3F74-B0FF-E811-8127-0CC47A70A1C0	59930D03-6E20-4EB1-A76E-4C4C554A11D7	1	2	875D3F74-B0FF-E811-8127-0CC47A70A1C0	2	2087-01-01 18:10:44.443	CO	CONVERSING	AsyncLogService	D775EE0B-292D-4712-AECB-89C4559A6ED8	4	-1	00000000-0000-0000-0000-000000000000	00000000-0000-0000-0000-000000000000	1900-01-01 00:00:00.000	1900-01-01 00:00:00.000	270110	0xA627EF000000	-1	0	0	0	-1	0	0	1	5
895D3F74-B0FF-E811-8127-0CC47A70A1C0	1E5D472B-A2AB-46BF-9B1E-D2809A0B6054	1	2	8A5D3F74-B0FF-E811-8127-0CC47A70A1C0	2	2087-01-01 18:10:44.443	CO	CONVERSING	AsyncLogService	D775EE0B-292D-4712-AECB-89C4559A6ED8	4	-1	00000000-0000-0000-0000-000000000000	00000000-0000-0000-0000-000000000000	1900-01-01 00:00:00.000	1900-01-01 00:00:00.000	56359	0x9E27EF000000	-1	0	0	0	-1	0	0	1	5

в таблицах все очень плохо? должны быть пустые?
...
Рейтинг: 0 / 0
Service broker для логирования, глюки
    #39750269
invm
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Участник
КифирчикК сожалению отметки времени не уникальны, могут приходить две (и даже 5) одинаковые, и тогда проблематично понять в какой последовательности они появились. Если диалог в очереди имеет границы например в рамках одного @spid, или внутри одной ХП - то это позволило бы точно сохранить порядок вызовов, исходя из порядка появления сообщений в очереди.
Иначе - нужно формировать Stamp перед отправкой логируемого сообщения. Или последовательность длинючую использовать. Заведите в VTSDB2_LOG sequence, дергайте из него значения в других БД и передавайте полученное в сообщении.
Кифирчикв таблицах все очень плохо? должны быть пустые?Нет, все более-менее.
Из той, которая в LOG, нужно прибить строки с state_desc = 'CLOSED' путем вызовов end conversation ... with clean up
...
Рейтинг: 0 / 0
18 сообщений из 43, страница 2 из 2
Форумы / Microsoft SQL Server [игнор отключен] [закрыт для гостей] / Service broker для логирования, глюки
Найденые пользователи ...
Разблокировать пользователей ...
Читали форум (0):
Пользователи онлайн (0):
x
x
Закрыть


Просмотр
0 / 0
Close
Debug Console [Select Text]