https://docs.microsoft.com/ja-jp/azure/azure-functions/functions-bindings-storage-queue-trigger?tabs=csharp
上記のサイトに載っている、queueの変更や追加をトリガーとして、queueの中身を表示するコード
Python
1 2import logging 3import json 4 5import azure.functions as func 6 7def main(msg: func.QueueMessage): 8 logging.info('Python queue trigger function processed a queue item.') 9 10 result = json.dumps({ 11 'id': msg.id, 12 'body': msg.get_body().decode('utf-8'), 13 'expiration_time': (msg.expiration_time.isoformat() 14 if msg.expiration_time else None), 15 'insertion_time': (msg.insertion_time.isoformat() 16 if msg.insertion_time else None), 17 'time_next_visible': (msg.time_next_visible.isoformat() 18 if msg.time_next_visible else None), 19 'pop_receipt': msg.pop_receipt, 20 'dequeue_count': msg.dequeue_count 21 }) 22 23 logging.info(result)
を実行したところ、queueに追加したメッセージは上記のプログラムで処理されたあと自動的に消去されていました。
azure queue storageではそのような挙動が正常なのですか?
また、メッセージが取り出された回数を表すqueueの属性としてdequeue countがあるのですが、今回のように取り出されたら消去されるのにdequeue countはどのような時に使うことを想定されているのでしょうか
教えてくださると助かります。
あなたの回答
tips
プレビュー