Na początek chciałbym powiedzieć, że jeśli ktoś może tu pomóc, jesteś niesamowity.
Pytanie ogólne
Mój program Python musi wchodzić w interakcje z MSMQ. Zasadniczo chcę zerknąć do kolejki, określając limit czasu, jeśli nie ma nic w kolejce.
Jednak pomimo moich najlepszych starań nie mogę zmusić Peek () do przekroczenia limitu czasu, gdy wcześniej nie ma żadnej wartości w kolejce. Czy możesz wskazać, czego brakuje w tym kodzie?
Mój obecny kod
Oto mój kod w tej chwili:
from socket import gethostname
import win32com.client
import pythoncom
import clr
clr.AddReference("System")
clr.AddReference("System.Messaging")
from System import TimeSpan
from System.Messaging import MessageQueue
# Source: [1]
# [1] https://docs.microsoft.com/en-us/previous-versions/windows/desktop/msmq/ms707027%28v%3dvs.85%29
MQ_DENY_NONE = 0x0
MQ_PEEK_ACCESS = 0x1
MQ_SEND_ACCESS = 0x2
# Set up queue
pythoncom.CoInitialize()
qinfo = win32com.client.Dispatch("MSMQ.MSMQQueueInfo")
qinfo.FormatName = f"direct=os:{gethostname()}\\PRIVATE$\\MyQueue"
queue = qinfo.Open(MQ_PEEK_ACCESS, MQ_DENY_NONE)
# Receive a value
timeout_sec = 1.0
timespan = TimeSpan.FromSeconds(timeout_sec)
label, body = "", ""
# TODO: timeout value does not appear working. It never waits when
# there's no message
if queue.Peek(pythoncom.Empty, pythoncom.Empty, timespan):
msg = queue.Receive() . # Blocking receive --> remove msg from the queue
if msg is not None:
label = msg.Label
body = msg.Body
Biegam: inspect.getfullargspec(queue.Peek)
i dostaję:
FullArgSpec(args=['self', 'WantDestinationQueue', 'WantBody', 'ReceiveTimeout', 'WantConnectorType'], varargs=None, varkw=None, defaults=(<PyOleMissing object at 0x00000147F5D43BD0>, <PyOleMissing object at 0x00000147F5D43BD0>, <PyOleMissing object at 0x00000147F5D43BD0>, <PyOleMissing object at 0x00000147F5D43BD0>), kwonlyargs=[], kwonlydefaults=None, annotations={})
Rzeczy, które próbowałem
To pytanie : powiedzenie ReceiveTimeout=timespan
nie rozwiązuje mojego problemu.
Wymiana pythoncom.Empty
z pythoncom.Missing
nie wydają się działać
To pytanie bez odpowiedzi wydaje się bardzo podobne do mojego
CoWaitForMultipleHandles(Flags, Timeout , Handles )
to pomóc?queue.Peek
Odpowiedzi:
Znalazłem ten artykuł wysyłanie-msmq-messages-python
W tym artykule pokazano, jak wysyłać i odbierać wiadomości za pomocą msmq. Nie rozumiem, dlaczego nie można po prostu użyć standardowej składni połączenia gniazda, aby powiedzieć, że jeśli nie otrzymałem pakietu / połączenia, to zamknij połączenie
Coś takiego nie powinno być zbyt trudne. Scenariusz najgorszego przypadku tworzy wątek, który sprawdza za każdym razem timeout_time, czy zmienna ma wartość zero, czy nie. Jeśli jest to zerowa kolejka zamknięta, nic nie zostanie odebrane, jeśli jest> 0 ustawione na zero i czeka na więcej wiadomości. Znalazłem również GitHub o asynchronicznym msmq do rejestrowania w Pythonie. asynchroniczny msmq Ten właśnie powiedział, że odbiera, podczas gdy True dlopes7 msmq
Nie odpowiedź, którą chciałeś, ale taka, która zadziała.
źródło
W komentarzach do pierwotnego pytania @PeterBrittain sugerował, aby spróbować po prostu użyć:
Zacząłem próbować tego i faktycznie zadziałało! Znalazłem
float
wartości, które również działają. Oto przykładowy kod Python:Dziękuję @PeterBrittain!
źródło