Я создал очередь служебной шины с разрешениями на отправку и прослушивание.
Используя язык программирования C #, я могу читать данные из этой очереди.
Но когда я пытаюсь сделать то же самое с python, я сталкиваюсь с некоторыми проблемами, также я новичок в Python и использую с ним службы Azure. Ниже приведены фрагменты кода, которые дают мне ошибку.
Фрагмент 1
from azure.servicebus import QueueClient, Message
# Create the QueueClient
queue_client = QueueClient.from_connection_string(
"<CONNECTION STRING>", "<QUEUE NAME>")
# Receive the message from the queue
with queue_client.get_receiver() as queue_receiver:
messages = queue_receiver.fetch_next(timeout=3)
for message in messages:
print(message)
message.complete()
Ошибка
Traceback (most recent call last):
File "C:\installs\readBus1.py", line 1, in <module>
from azure.servicebus import QueueClient, Message
ImportError: cannot import name 'QueueClient'
Фрагмент 2
from azure.servicebus.control_client import ServiceBusService, Message, Topic, Rule, DEFAULT_RULE_NAME
bus_service = ServiceBusService(
service_namespace='<NameSpace>',
shared_access_key_name='<KeyName>',
shared_access_key_value='<ConnectionString>')
msg = bus_service.receive_subscription_message('fileupload', 'AllMessages', peek_lock=True)
if msg.body is not None:
print(msg.body)
msg.delete()
Ошибка
Traceback (most recent call last):
File "C:\installs\readBus1.py", line 2, in <module>
from azure.servicebus.control_client import ServiceBusService, Message, Topic, Rule, DEFAULT_RULE_NAME
ModuleNotFoundError: No module named 'azure.servicebus.control_client'
Я использую Python 3.6, также я установил службы Azure с помощью команды
pip install azure
Я новичок в Python и использую его с Azure.