check change event type before container name (#1075)

This commit is contained in:
bmc-msft
2021-07-15 19:57:41 -04:00
committed by GitHub
parent f769364335
commit db66a1d3c5

View File

@ -29,10 +29,11 @@ def file_added(event: Dict, fail_task_on_transient_error: bool) -> None:
def main(msg: func.QueueMessage, dashboard: func.Out[str]) -> None:
event = json.loads(msg.get_body())
last_try = msg.dequeue_count == MAX_DEQUEUE_COUNT
if event["topic"] not in corpus_accounts():
# check type first before calling Azure APIs
if event["eventType"] != "Microsoft.Storage.BlobCreated":
return
if event["eventType"] != "Microsoft.Storage.BlobCreated":
if event["topic"] not in corpus_accounts():
return
file_added(event, last_try)