Example usage of AWS SQS

aws_sqs_example.ipynb

{
 "cells": [
  {
   "cell_type": "code",
   "execution_count": 1,
   "metadata": {},
   "outputs": [],
   "source": [
    "import boto3"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 3,
   "metadata": {},
   "outputs": [],
   "source": [
    "sqs = boto3.resource('sqs')\n",
    "fifo = sqs.create_queue(QueueName=\"MyTestQueue\")\n",
    "fifo = sqs.get_queue_by_name(QueueName=\"MyTestQueue\")"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 32,
   "metadata": {},
   "outputs": [],
   "source": [
    "for i in range(0,200): \n",
    "    fifo.send_message(MessageBody=\"message {}\".format(i))"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 34,
   "metadata": {},
   "outputs": [
    {
     "name": "stdout",
     "output_type": "stream",
     "text": [
      "message 1\n",
      "message 3\n",
      "message 9\n",
      "message 5\n",
      "message 6\n",
      "message 12\n",
      "message 15\n",
      "message 24\n",
      "message 31\n",
      "message 10\n",
      "message 32\n",
      "message 33\n",
      "message 4\n",
      "message 0\n",
      "message 13\n",
      "message 14\n",
      "message 36\n",
      "message 17\n",
      "message 34\n",
      "message 39\n",
      "message 7\n",
      "message 18\n",
      "message 44\n",
      "message 40\n",
      "message 11\n",
      "message 20\n",
      "message 23\n",
      "message 25\n",
      "message 22\n",
      "message 8\n",
      "message 35\n",
      "message 26\n",
      "message 56\n",
      "message 47\n",
      "message 48\n",
      "message 53\n",
      "message 58\n",
      "message 62\n",
      "message 30\n",
      "message 16\n",
      "message 65\n",
      "message 63\n",
      "message 50\n",
      "message 19\n",
      "message 28\n",
      "message 74\n",
      "message 37\n",
      "message 79\n",
      "message 54\n",
      "message 21\n",
      "message 55\n",
      "message 29\n",
      "message 27\n",
      "message 87\n",
      "message 49\n",
      "message 57\n",
      "message 72\n",
      "message 41\n",
      "message 66\n",
      "message 82\n",
      "message 38\n",
      "message 42\n",
      "message 45\n",
      "message 76\n",
      "message 60\n",
      "message 77\n",
      "message 80\n",
      "message 95\n",
      "message 43\n",
      "message 52\n",
      "message 59\n",
      "message 46\n",
      "message 97\n",
      "message 81\n",
      "message 61\n",
      "message 86\n",
      "message 96\n",
      "message 99\n",
      "message 64\n",
      "message 51\n",
      "message 68\n",
      "message 67\n",
      "message 69\n",
      "message 70\n",
      "message 71\n",
      "message 103\n",
      "message 84\n",
      "message 73\n",
      "message 107\n",
      "message 105\n",
      "message 78\n",
      "message 128\n",
      "message 139\n",
      "message 113\n",
      "message 144\n",
      "message 75\n",
      "message 145\n",
      "message 157\n",
      "message 88\n",
      "message 91\n",
      "message 92\n",
      "message 83\n",
      "message 100\n",
      "message 106\n",
      "message 101\n",
      "message 85\n",
      "message 89\n",
      "message 116\n",
      "message 98\n",
      "message 159\n",
      "message 90\n",
      "message 129\n",
      "message 118\n",
      "message 109\n",
      "message 114\n",
      "message 171\n",
      "message 93\n",
      "message 124\n",
      "message 133\n",
      "message 104\n",
      "message 179\n",
      "message 94\n",
      "message 136\n",
      "message 130\n",
      "message 134\n",
      "message 153\n",
      "message 108\n",
      "message 154\n",
      "message 137\n",
      "message 115\n",
      "message 102\n",
      "message 161\n",
      "message 110\n",
      "message 146\n",
      "message 117\n",
      "message 165\n",
      "message 111\n",
      "message 180\n",
      "message 126\n",
      "message 195\n",
      "message 112\n",
      "message 120\n",
      "message 119\n",
      "message 122\n",
      "message 149\n",
      "message 125\n",
      "message 140\n",
      "message 121\n",
      "message 158\n",
      "message 123\n",
      "message 131\n",
      "message 162\n",
      "message 167\n",
      "message 127\n",
      "message 132\n",
      "message 166\n",
      "message 138\n",
      "message 147\n",
      "message 135\n",
      "message 170\n",
      "message 141\n",
      "message 172\n",
      "message 152\n",
      "message 173\n",
      "message 175\n",
      "message 142\n",
      "message 151\n",
      "message 155\n",
      "message 163\n",
      "message 182\n",
      "message 143\n",
      "message 156\n",
      "message 148\n",
      "message 186\n",
      "message 189\n",
      "message 176\n",
      "message 150\n",
      "message 164\n",
      "message 174\n",
      "message 160\n",
      "message 169\n",
      "message 177\n",
      "message 178\n",
      "message 191\n",
      "message 190\n",
      "message 168\n",
      "message 183\n",
      "message 185\n",
      "message 184\n",
      "message 188\n",
      "message 197\n",
      "message 198\n",
      "message 181\n",
      "message 187\n",
      "message 199\n",
      "message 192\n",
      "message 193\n",
      "message 194\n",
      "message 196\n",
      "empty\n"
     ]
    }
   ],
   "source": [
    "while True:\n",
    "    msgs = fifo.receive_messages()\n",
    "    if(len(msgs)!=0):\n",
    "        for msg in msgs:\n",
    "            print(msg.body)\n",
    "            msg.delete()\n",
    "    else:\n",
    "        print(\"empty\")\n",
    "        break\n",
    "        "
   ]
  },
  {
   "cell_type": "code",
   "execution_count": null,
   "metadata": {},
   "outputs": [],
   "source": []
  }
 ],
 "metadata": {
  "kernelspec": {
   "display_name": "Python 3",
   "language": "python",
   "name": "python3"
  },
  "language_info": {
   "codemirror_mode": {
    "name": "ipython",
    "version": 3
   },
   "file_extension": ".py",
   "mimetype": "text/x-python",
   "name": "python",
   "nbconvert_exporter": "python",
   "pygments_lexer": "ipython3",
   "version": "3.6.4"
  }
 },
 "nbformat": 4,
 "nbformat_minor": 2
}