ServiceBusReceiver Sınıf

İletiyi bırakın.

Bu ileti kuyruğa döndürülür ve yeniden alınabilir hale getirilecektir.

async abandon_message(message: ServiceBusReceivedMessage) -> None

Parametreler

Dönüş türü

Özel durumlar

Örnekler

Alınan iletiyi bırakma.

       messages = await servicebus_receiver.receive_messages(max_wait_time=5)
       for message in messages:
           await servicebus_receiver.abandon_message(message)

async close() -> None

Özel durumlar

İletiyi tamamlayın.

Bu işlem, iletiyi kuyruktan kaldırır.

async complete_message(message: ServiceBusReceivedMessage) -> None

Parametreler

Dönüş türü

Özel durumlar

Örnekler

Alınan iletiyi tamamlayın.

       messages = await servicebus_receiver.receive_messages(max_wait_time=5)
       for message in messages:
           await servicebus_receiver.complete_message(message)

İletiyi Teslim Edilemeyen İleti kuyruğuna taşıyın.

Teslim Edilemeyen İleti kuyruğu, doğru işlenemeyen veya başka bir şekilde inceleme veya işleme gerektiren iletileri depolamak için kullanılabilecek bir alt sıradır. Kuyruk, süresi dolan iletileri Teslim Edilemeyen İleti kuyruğuna gönderecek şekilde de yapılandırılabilir.

async dead_letter_message(message: ServiceBusReceivedMessage, reason: str | None = None, error_description: str | None = None) -> None

Parametreler

Dönüş türü

Özel durumlar

Örnekler

Teslim edilemeyen ileti alındı.

       messages = await servicebus_receiver.receive_messages(max_wait_time=5)
       for message in messages:
           await servicebus_receiver.dead_letter_message(message)

İletiyi geçersiz hale getir.

Bu ileti kuyrukta kalır ancak alınabilmesi için özel olarak sıra numarasıyla istenmesi gerekir.

async defer_message(message: ServiceBusReceivedMessage) -> None

Parametreler

Dönüş türü

Özel durumlar

Örnekler

Alınan iletiyi erteleme.

       messages = await servicebus_receiver.receive_messages(max_wait_time=5)
       for message in messages:
           await servicebus_receiver.defer_message(message)

Kuyrukta bekleyen iletilere göz atın.

Göz atılan iletiler kuyruktan kaldırılmaz ve kilitlenmez. Bunlar tamamlanamaz, ertelenemez veya teslim edilemez.

async peek_messages(max_message_count: int = 1, *, sequence_number: int = 0, timeout: float | None = None, **kwargs: Any) -> List[ServiceBusReceivedMessage]

Parametreler

Döndürülenler

~azure.servicebus.ServiceBusReceivedMessage nesnelerinin listesi.

Dönüş türü

Özel durumlar

Örnekler

Kuyruktaki iletilere göz atın.

   async with servicebus_receiver:
       messages = await servicebus_receiver.peek_messages()
       for message in messages:
           print(str(message))

Daha önce ertelenmiş iletileri alma.

Bölümlenmiş bir varlıktan ertelenen iletiler alınırken, sağlanan tüm sıra numaralarının aynı bölümdeki iletiler olması gerekir.

async receive_deferred_messages(sequence_numbers: int | List[int], *, timeout: float | None = None, **kwargs: Any) -> List[ServiceBusReceivedMessage]

Parametreler

Döndürülenler

Alınan iletilerin listesi.

Dönüş türü

Özel durumlar

Örnekler

ServiceBus'tan ertelenen iletiler alın.

   async with servicebus_receiver:
       deferred_sequenced_numbers = []
       messages = await servicebus_receiver.receive_messages(max_wait_time=5)
       for message in messages:
           deferred_sequenced_numbers.append(message.sequence_number)
           print(str(message))
           await servicebus_receiver.defer_message(message)

       received_deferred_msg = await servicebus_receiver.receive_deferred_messages(
           sequence_numbers=deferred_sequenced_numbers
       )

       for message in received_deferred_msg:
           await servicebus_receiver.complete_message(message)

Bir kerede bir toplu ileti alın.

Birden çok iletiyi aynı anda işlemek veya tek bir çağrı olarak geçici bir alma gerçekleştirmek istiyorsanız bu yaklaşım en uygun yöntemdir.

Tek bir toplu işlemde alınan ileti sayısının, alıcı için prefetch_count ayarlanıp ayarlanmadığına bağlı olacağını unutmayın. Alıcı için prefetch_count ayarlanmadıysa, alıcı max_message_count (sağlanırsa) iletileri hizmete yönelik istek içinde önbelleğe almaya çalışır.

Bu çağrı, belirtilen toplu iş boyutuna göre hızlı döndürmeyi önceliklendirir ve en az bir ileti alınır alınmaz ve belirtilen toplu iş boyutundan bağımsız olarak gelen iletilerde boşluk olur.

async receive_messages(max_message_count: int | None = 1, max_wait_time: float | None = None) -> List[ServiceBusReceivedMessage]

Parametreler

Döndürülenler

Alınan iletilerin listesi. Kullanılabilir ileti yoksa, bu boş bir liste olur.

Dönüş türü

Özel durumlar

Örnekler

ServiceBus'tan ileti alma.

   async with servicebus_receiver:
       messages = await servicebus_receiver.receive_messages(max_wait_time=5)
       for message in messages:
           print(str(message))
           await servicebus_receiver.complete_message(message)

İleti kilidini yenileyin.

Bu, iletinin yeniden işlenecek kuyruğa döndürülmemesini sağlamak için iletinin kilidini korur.

İletiyi tamamlamak (veya başka bir şekilde çözmek) için kilidin korunması gerekir ve süresi dolmuş olamaz; süresi dolmuş bir kilit yenilenemez.

RECEIVE_AND_DELETE modu aracılığıyla alınan iletiler kilitli değildir ve bu nedenle yenilenemez. Bu işlem yalnızca oturum olmayan iletiler için de kullanılabilir.

async renew_message_lock(message: ServiceBusReceivedMessage, *, timeout: float | None = None, **kwargs: Any) -> datetime

Parametreler

Döndürülenler

Kilidin sona erecek şekilde ayarlandığı utc tarih saati.

Dönüş türü

Özel durumlar

Örnekler

Alınan iletideki kilidi yenileyin.

       messages = await servicebus_receiver.receive_messages(max_wait_time=5)
       for message in messages:
           await servicebus_receiver.renew_message_lock(message)

Alıcı örneğiyle ilişkili ServiceBusReceiver istemci tanımlayıcısını alın.

Dönüş türü

ServiceBusSession nesnesini alıcıyla ilişkilendirin. Oturum yalnızca oturum etkin varlıklar için kullanılabilir; oturum olmayan bir alıcıda çağrılırsa Hiçbiri döndürür.

Dönüş türü

Örnekler

Alıcıdan oturum alma

       async with servicebus_client.get_queue_receiver(queue_name=queue_name, session_id=session_id) as receiver:
           session = receiver.session