Не получать все события InfoMessage с Python и win32com - PullRequest
Новая
       28

Не получать все события InfoMessage с Python и win32com

0 голосов
/ 04 мая 2011

В настоящее время я пытаюсь получить процент завершенных сообщений, возвращаемых событием InfoMessage от ADO (и сервера SQL) при выполнении команды BACKUP. (Подробнее см. Мой предыдущий вопрос).

Мне удалось подключиться к серверу SQL и выдать ему команды SQL, и событие получило события обратно. Однако, когда я выполняю команду BACKUP, метод cmd.Execute блокируется, пока резервное копирование не будет завершено.

Но в течение этого времени я получу одиночный InfoMessage вызов события (который будет иметь сообщение типа «1 процент завершен»), и после этого я больше не буду получать события.

Я пробовал это с помощью хранимой процедуры, где хранимая процедура печатает 3 сообщения, и даже здесь я получу первое сообщение и ничего больше.

Я подозреваю, что мне нужно позвонить pythoncom.PumpWaitingMessages(), но из-за блокирования вызова cmd.Execute() я никогда ничего не получу.

Может кто-нибудь узнать, как получить больше, чем одно InfoMessage событие.

Ниже приведен код, который я сейчас использую: 

import win32com
import pythoncom
import adodbapi
import time
import win32gui
from win32com.client import gencache
gencache.EnsureModule('{2A75196C-D9EB-4129-B803-931327F72D5C}', 0, 2, 8)

defaultNamedOptArg=pythoncom.Empty
defaultNamedNotOptArg=pythoncom.Empty
defaultUnnamedArg=pythoncom.Empty

global connected
connected = False

class events():
    def OnInfoMessage(self, pError, adStatus, pConnection):
        print 'Info Message'
        a = pError.QueryInterface(pythoncom.IID_IDispatch)
        a = win32com.client.Dispatch(a)
        print a.Description
        print a.Number
        print a.Source
        #print 'B', adStatus
        c = pConnection.QueryInterface(pythoncom.IID_IDispatch)
        c = win32com.client.Dispatch(c)
        print c.Errors.Count
        print c.Errors.Item(0).Description
        return 1

    def OnCommitTransComplete(self, pError=defaultNamedNotOptArg, adStatus=defaultNamedNotOptArg, pConnection=defaultNamedNotOptArg): pass
    def OnWillExecute(self, Source=defaultNamedNotOptArg, CursorType=defaultNamedNotOptArg, LockType=defaultNamedNotOptArg, Options=defaultNamedNotOptArg
            , adStatus=defaultNamedNotOptArg, pCommand=defaultNamedNotOptArg, pRecordset=defaultNamedNotOptArg, pConnection=defaultNamedNotOptArg):
        print 'Execute Event'
        return Source
    def OnDisconnect(self, adStatus=defaultNamedNotOptArg, pConnection=defaultNamedNotOptArg): 
        print 'Disconnected'
    def OnExecuteComplete(self, RecordsAffected=defaultNamedNotOptArg, pError=defaultNamedNotOptArg, adStatus=defaultNamedNotOptArg, pCommand=defaultNamedNotOptArg
            , pRecordset=defaultNamedNotOptArg, pConnection=defaultNamedNotOptArg):
        print 'Execute complete'
    def OnWillConnect(self, ConnectionString=defaultNamedNotOptArg, UserID=defaultNamedNotOptArg, Password=defaultNamedNotOptArg, Options=defaultNamedNotOptArg
            , adStatus=defaultNamedNotOptArg, pConnection=defaultNamedNotOptArg):
        print 'About to connect'
    def OnConnectComplete(self, pError=defaultNamedNotOptArg, adStatus=defaultNamedNotOptArg, pConnection=defaultNamedNotOptArg):
        print 'Connected'
        global connected
        connected = True
    def OnBeginTransComplete(self, TransactionLevel=defaultNamedNotOptArg, pError=defaultNamedNotOptArg, adStatus=defaultNamedNotOptArg, pConnection=defaultNamedNotOptArg):pass
    def OnRollbackTransComplete(self, pError=defaultNamedNotOptArg, adStatus=defaultNamedNotOptArg, pConnection=defaultNamedNotOptArg): pass

if __name__ == '__main__':

    pythoncom.CoInitialize()
    conn = win32com.client.DispatchWithEvents("ADODB.Connection", events)

    conn.ConnectionString = 'Data Source=HPDX2250RAAZ\\SQLEXPRESS; Provider=SQLOLEDB; Integrated Security=SSPI'
    conn.CommandTimeout = 30
    conn.CursorLocation = 2
    conn.Open(pythoncom.Empty,pythoncom.Empty,pythoncom.Empty,0x10)

    while not connected:
        #pythoncom.PumpWaitingMessages()
        win32gui.PumpWaitingMessages()
        time.sleep(0.1)

    conn.BeginTrans()
    conn.Errors.Clear()
    cmd=win32com.client.Dispatch("ADODB.Command")
    cmd.ActiveConnection=conn
    cmd.CommandTimeout = 30  #v2.1 Simons
    cmd.CommandText="EXECUTE [test].[dbo].[Test] "
    print 'Execute'
    cmd.Execute()

    pythoncom.PumpWaitingMessages()
    print 'Called'
    print ''
    print conn.Errors.Count
    conn.RollbackTrans()
    conn.Close()

Ответы [ 2 ]

1 голос
/ 30 июня 2011

У меня была та же проблема, и в чем проблема, если у вас возникла та же проблема, то, что сообщения в основном задерживаются самим ядром SQL Server. Чтобы обойти это, нужно сказать SQL не ждать окончания обработки для отправки сообщений, а отправлять их по мере их появления. Попробуйте это для размера: 

SET @message = 'My message...'
RAISERROR (@message, 10, 1) WITH NOWAIT

Это должно послать сообщение, и ваш внешний интерфейс должен забрать их по мере продвижения системы.

Надеюсь, это поможет

0 голосов
/ 21 декабря 2012

Я нашел обходной путь, который совместим с pymssql и другими драйверами.Я использую SQL из Существует ли сценарий SQL, который я могу использовать для определения хода процесса резервного копирования или восстановления SQL Server? плюс фоновый поток, который каждые X секунд выполняет этот запрос.Теперь для уведомления я использую http://pydispatcher.sourceforge.net/, чтобы получить информацию о прогрессе. 

#This is rough extract from my actual code. Probably not work as is, but outline the idea
import dispatch #Decoupled send of messages, identical to django signals

def monitorBackup(self):
    return self.selectSql(SQL_MONITOR)

def backup(sql):
    con = self.getCon() #Get new connection, we are in another thread!
    con.execute_query("HERE THE BACKUP SQL")

result = threading.Thread(target=partial(backup, sql))

result.start()

while result.isAlive():
    time.sleep(5) # with the monitor SQL result, is possible to get a estimated time to complete and adjust this...
    rows = self.monitorBackup()

    if len(rows) > 0:
        percentage = rows[0].Percent

        self.send(
            msg="%d %%" % percentage,
            action="progress",
            progress=percentage
        )
...