{"id":"6c61c8fe-4dd3-4cfe-a07b-5f70787a8f2d","shortId":"Sje9Xu","kind":"skill","title":"azure-storage-queue-py","tagline":"Azure Queue Storage SDK for Python. Use for reliable message queuing, task distribution, and asynchronous processing.","description":"# Azure Queue Storage SDK for Python\n\nSimple, cost-effective message queuing for asynchronous communication.\n\n## Installation\n\n```bash\npip install azure-storage-queue azure-identity\n```\n\n## Environment Variables\n\n```bash\nAZURE_STORAGE_ACCOUNT_URL=https://<account>.queue.core.windows.net\n```\n\n## Authentication\n\n```python\nfrom azure.identity import DefaultAzureCredential\nfrom azure.storage.queue import QueueServiceClient, QueueClient\n\ncredential = DefaultAzureCredential()\naccount_url = \"https://<account>.queue.core.windows.net\"\n\n# Service client\nservice_client = QueueServiceClient(account_url=account_url, credential=credential)\n\n# Queue client\nqueue_client = QueueClient(account_url=account_url, queue_name=\"myqueue\", credential=credential)\n```\n\n## Queue Operations\n\n```python\n# Create queue\nservice_client.create_queue(\"myqueue\")\n\n# Get queue client\nqueue_client = service_client.get_queue_client(\"myqueue\")\n\n# Delete queue\nservice_client.delete_queue(\"myqueue\")\n\n# List queues\nfor queue in service_client.list_queues():\n    print(queue.name)\n```\n\n## Send Messages\n\n```python\n# Send message (string)\nqueue_client.send_message(\"Hello, Queue!\")\n\n# Send with options\nqueue_client.send_message(\n    content=\"Delayed message\",\n    visibility_timeout=60,  # Hidden for 60 seconds\n    time_to_live=3600       # Expires in 1 hour\n)\n\n# Send JSON\nimport json\ndata = {\"task\": \"process\", \"id\": 123}\nqueue_client.send_message(json.dumps(data))\n```\n\n## Receive Messages\n\n```python\n# Receive messages (makes them invisible temporarily)\nmessages = queue_client.receive_messages(\n    messages_per_page=10,\n    visibility_timeout=30  # 30 seconds to process\n)\n\nfor message in messages:\n    print(f\"ID: {message.id}\")\n    print(f\"Content: {message.content}\")\n    print(f\"Dequeue count: {message.dequeue_count}\")\n    \n    # Process message...\n    \n    # Delete after processing\n    queue_client.delete_message(message)\n```\n\n## Peek Messages\n\n```python\n# Peek without hiding (doesn't affect visibility)\nmessages = queue_client.peek_messages(max_messages=5)\n\nfor message in messages:\n    print(message.content)\n```\n\n## Update Message\n\n```python\n# Extend visibility or update content\nmessages = queue_client.receive_messages()\nfor message in messages:\n    # Extend timeout (need more time)\n    queue_client.update_message(\n        message,\n        visibility_timeout=60\n    )\n    \n    # Update content and timeout\n    queue_client.update_message(\n        message,\n        content=\"Updated content\",\n        visibility_timeout=60\n    )\n```\n\n## Delete Message\n\n```python\n# Delete after successful processing\nmessages = queue_client.receive_messages()\nfor message in messages:\n    try:\n        # Process...\n        queue_client.delete_message(message)\n    except Exception:\n        # Message becomes visible again after timeout\n        pass\n```\n\n## Clear Queue\n\n```python\n# Delete all messages\nqueue_client.clear_messages()\n```\n\n## Queue Properties\n\n```python\n# Get queue properties\nproperties = queue_client.get_queue_properties()\nprint(f\"Approximate message count: {properties.approximate_message_count}\")\n\n# Set/get metadata\nqueue_client.set_queue_metadata(metadata={\"environment\": \"production\"})\nproperties = queue_client.get_queue_properties()\nprint(properties.metadata)\n```\n\n## Async Client\n\n```python\nfrom azure.storage.queue.aio import QueueServiceClient, QueueClient\nfrom azure.identity.aio import DefaultAzureCredential\n\nasync def queue_operations():\n    credential = DefaultAzureCredential()\n    \n    async with QueueClient(\n        account_url=\"https://<account>.queue.core.windows.net\",\n        queue_name=\"myqueue\",\n        credential=credential\n    ) as client:\n        # Send\n        await client.send_message(\"Async message\")\n        \n        # Receive\n        async for message in client.receive_messages():\n            print(message.content)\n            await client.delete_message(message)\n\nimport asyncio\nasyncio.run(queue_operations())\n```\n\n## Base64 Encoding\n\n```python\nfrom azure.storage.queue import QueueClient, BinaryBase64EncodePolicy, BinaryBase64DecodePolicy\n\n# For binary data\nqueue_client = QueueClient(\n    account_url=account_url,\n    queue_name=\"myqueue\",\n    credential=credential,\n    message_encode_policy=BinaryBase64EncodePolicy(),\n    message_decode_policy=BinaryBase64DecodePolicy()\n)\n\n# Send bytes\nqueue_client.send_message(b\"Binary content\")\n```\n\n## Best Practices\n\n1. **Delete messages after processing** to prevent reprocessing\n2. **Set appropriate visibility timeout** based on processing time\n3. **Handle `dequeue_count`** for poison message detection\n4. **Use async client** for high-throughput scenarios\n5. **Use `peek_messages`** for monitoring without affecting queue\n6. **Set `time_to_live`** to prevent stale messages\n7. **Consider Service Bus** for advanced features (sessions, topics)\n\n## When to Use\nThis skill is applicable to execute the workflow or actions described in the overview.\n\n## Limitations\n- Use this skill only when the task clearly matches the scope described above.\n- Do not treat the output as a substitute for environment-specific validation, testing, or expert review.\n- Stop and ask for clarification if required inputs, permissions, safety boundaries, or success criteria are missing.","tags":["azure","storage","queue","antigravity","awesome","skills","sickn33","agent-skills","agentic-skills","ai-agent-skills","ai-agents","ai-coding"],"capabilities":["skill","source-sickn33","skill-azure-storage-queue-py","topic-agent-skills","topic-agentic-skills","topic-ai-agent-skills","topic-ai-agents","topic-ai-coding","topic-ai-workflows","topic-antigravity","topic-antigravity-skills","topic-claude-code","topic-claude-code-skills","topic-codex-cli","topic-codex-skills"],"categories":["antigravity-awesome-skills"],"synonyms":[],"warnings":[],"endpointUrl":"https://skills.sh/sickn33/antigravity-awesome-skills/azure-storage-queue-py","protocol":"skill","transport":"skills-sh","auth":{"type":"none","details":{"cli":"npx skills add sickn33/antigravity-awesome-skills","source_repo":"https://github.com/sickn33/antigravity-awesome-skills","install_from":"skills.sh"}},"qualityScore":"0.700","qualityRationale":"deterministic score 0.70 from registry signals: · indexed on github topic:agent-skills · 34928 github stars · SKILL.md body (5,243 chars)","verified":false,"liveness":"unknown","lastLivenessCheck":null,"agentReviews":{"count":0,"score_avg":null,"cost_usd_avg":null,"success_rate":null,"latency_p50_ms":null,"narrative_summary":null,"summary_updated_at":null},"enrichmentModel":"deterministic:skill-github:v1","enrichmentVersion":1,"enrichedAt":"2026-04-24T18:50:34.665Z","embedding":null,"createdAt":"2026-04-18T21:33:15.735Z","updatedAt":"2026-04-24T18:50:34.665Z","lastSeenAt":"2026-04-24T18:50:34.665Z","tsv":"'1':159,448 '10':189 '123':169 '2':456 '3':465 '30':192,193 '3600':156 '4':473 '5':238,482 '6':491 '60':148,151,270,283 '7':500 'account':53,69,77,79,88,90,373,422,424 'action':521 'advanc':505 'affect':231,489 'applic':515 'appropri':458 'approxim':332 'ask':559 'async':352,364,370,387,390,475 'asynchron':20,35 'asyncio':403 'asyncio.run':404 'authent':56 'await':384,398 'azur':2,6,22,42,46,51 'azure-ident':45 'azure-storage-queu':41 'azure-storage-queue-pi':1 'azure.identity':59 'azure.identity.aio':361 'azure.storage.queue':63,411 'azure.storage.queue.aio':356 'b':443 'base':461 'base64':407 'bash':38,50 'becom':306 'best':446 'binari':417,444 'binarybase64decodepolicy':415,438 'binarybase64encodepolicy':414,434 'boundari':567 'bus':503 'byte':440 'clarif':561 'clear':312,534 'client':73,75,84,86,107,109,112,353,382,420,476 'client.delete':399 'client.receive':394 'client.send':385 'communic':36 'consid':501 'content':143,207,252,272,278,280,445 'cost':30 'cost-effect':29 'count':212,214,334,337,468 'creat':100 'credenti':67,81,82,95,96,368,379,380,429,430 'criteria':570 'data':165,173,418 'decod':436 'def':365 'defaultazurecredenti':61,68,363,369 'delay':144 'delet':114,217,284,287,315,449 'dequeu':211,467 'describ':522,538 'detect':472 'distribut':18 'doesn':229 'effect':31 'encod':408,432 'environ':48,344,550 'environment-specif':549 'except':303,304 'execut':517 'expert':555 'expir':157 'extend':248,260 'f':202,206,210,331 'featur':506 'get':105,323 'handl':466 'hello':136 'hidden':149 'hide':228 'high':479 'high-throughput':478 'hour':160 'id':168,203 'ident':47 'import':60,64,163,357,362,402,412 'input':564 'instal':37,40 'invis':181 'json':162,164 'json.dumps':172 'limit':526 'list':119 'live':155,495 'make':179 'match':535 'max':236 'messag':15,32,129,132,135,142,145,171,175,178,183,185,186,198,200,216,221,222,224,233,235,237,240,242,246,253,255,257,259,266,267,276,277,285,291,293,295,297,301,302,305,317,319,333,336,386,388,392,395,400,401,431,435,442,450,471,485,499 'message.content':208,244,397 'message.dequeue':213 'message.id':204 'metadata':339,342,343 'miss':572 'monitor':487 'myqueu':94,104,113,118,378,428 'name':93,377,427 'need':262 'oper':98,367,406 'option':140 'output':544 'overview':525 'page':188 'pass':311 'peek':223,226,484 'per':187 'permiss':565 'pip':39 'poison':470 'polici':433,437 'practic':447 'prevent':454,497 'print':126,201,205,209,243,330,350,396 'process':21,167,196,215,219,290,299,452,463 'product':345 'properti':321,325,326,329,346,349 'properties.approximate':335 'properties.metadata':351 'py':5 'python':11,27,57,99,130,176,225,247,286,314,322,354,409 'queu':16,33 'queue':4,7,23,44,83,85,92,97,101,103,106,108,111,115,117,120,122,125,137,313,320,324,328,341,348,366,376,405,419,426,490 'queue.core.windows.net':55,71,375 'queue.name':127 'queue_client.clear':318 'queue_client.delete':220,300 'queue_client.get':327,347 'queue_client.peek':234 'queue_client.receive':184,254,292 'queue_client.send':134,141,170,441 'queue_client.set':340 'queue_client.update':265,275 'queueclient':66,87,359,372,413,421 'queueservicecli':65,76,358 'receiv':174,177,389 'reliabl':14 'reprocess':455 'requir':563 'review':556 'safeti':566 'scenario':481 'scope':537 'sdk':9,25 'second':152,194 'send':128,131,138,161,383,439 'servic':72,74,502 'service_client.create':102 'service_client.delete':116 'service_client.get':110 'service_client.list':124 'session':507 'set':457,492 'set/get':338 'simpl':28 'skill':513,529 'skill-azure-storage-queue-py' 'source-sickn33' 'specif':551 'stale':498 'stop':557 'storag':3,8,24,43,52 'string':133 'substitut':547 'success':289,569 'task':17,166,533 'temporarili':182 'test':553 'throughput':480 'time':153,264,464,493 'timeout':147,191,261,269,274,282,310,460 'topic':508 'topic-agent-skills' 'topic-agentic-skills' 'topic-ai-agent-skills' 'topic-ai-agents' 'topic-ai-coding' 'topic-ai-workflows' 'topic-antigravity' 'topic-antigravity-skills' 'topic-claude-code' 'topic-claude-code-skills' 'topic-codex-cli' 'topic-codex-skills' 'treat':542 'tri':298 'updat':245,251,271,279 'url':54,70,78,80,89,91,374,423,425 'use':12,474,483,511,527 'valid':552 'variabl':49 'visibl':146,190,232,249,268,281,307,459 'without':227,488 'workflow':519","prices":[{"id":"16b0e383-660d-4275-a6ac-1e69d09c4d08","listingId":"6c61c8fe-4dd3-4cfe-a07b-5f70787a8f2d","amountUsd":"0","unit":"free","nativeCurrency":null,"nativeAmount":null,"chain":null,"payTo":null,"paymentMethod":"skill-free","isPrimary":true,"details":{"org":"sickn33","category":"antigravity-awesome-skills","install_from":"skills.sh"},"createdAt":"2026-04-18T21:33:15.735Z"}],"sources":[{"listingId":"6c61c8fe-4dd3-4cfe-a07b-5f70787a8f2d","source":"github","sourceId":"sickn33/antigravity-awesome-skills/azure-storage-queue-py","sourceUrl":"https://github.com/sickn33/antigravity-awesome-skills/tree/main/skills/azure-storage-queue-py","isPrimary":false,"firstSeenAt":"2026-04-18T21:33:15.735Z","lastSeenAt":"2026-04-24T18:50:34.665Z"}],"details":{"listingId":"6c61c8fe-4dd3-4cfe-a07b-5f70787a8f2d","quickStartSnippet":null,"exampleRequest":null,"exampleResponse":null,"schema":null,"openapiUrl":null,"agentsTxtUrl":null,"citations":[],"useCases":[],"bestFor":[],"notFor":[],"kindDetails":{"org":"sickn33","slug":"azure-storage-queue-py","github":{"repo":"sickn33/antigravity-awesome-skills","stars":34928,"topics":["agent-skills","agentic-skills","ai-agent-skills","ai-agents","ai-coding","ai-workflows","antigravity","antigravity-skills","claude-code","claude-code-skills","codex-cli","codex-skills","cursor","cursor-skills","developer-tools","gemini-cli","gemini-skills","kiro","mcp","skill-library"],"license":"mit","html_url":"https://github.com/sickn33/antigravity-awesome-skills","pushed_at":"2026-04-24T06:41:17Z","description":"Installable GitHub library of 1,400+ agentic skills for Claude Code, Cursor, Codex CLI, Gemini CLI, Antigravity, and more. Includes installer CLI, bundles, workflows, and official/community skill collections.","skill_md_sha":"db72e6906a9870223b1683d18c35effc1c96d7eb","skill_md_path":"skills/azure-storage-queue-py/SKILL.md","default_branch":"main","skill_tree_url":"https://github.com/sickn33/antigravity-awesome-skills/tree/main/skills/azure-storage-queue-py"},"layout":"multi","source":"github","category":"antigravity-awesome-skills","frontmatter":{"name":"azure-storage-queue-py","description":"Azure Queue Storage SDK for Python. Use for reliable message queuing, task distribution, and asynchronous processing."},"skills_sh_url":"https://skills.sh/sickn33/antigravity-awesome-skills/azure-storage-queue-py"},"updatedAt":"2026-04-24T18:50:34.665Z"}}