AIoT-secure-upload/4-subscribe-topic.ipynb

{
 "cells": [
  {
   "cell_type": "code",
   "execution_count": 1,
   "metadata": {},
   "outputs": [
    {
     "name": "stdout",
     "output_type": "stream",
     "text": [
      "/home/ec2-user/SageMaker/myAWSStudyBlog/AIoT-secure-upload/iot-beyoung-01\n"
     ]
    }
   ],
   "source": [
    "%cd iot-beyoung-01/"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 2,
   "metadata": {},
   "outputs": [],
   "source": [
    "from AWSIoTPythonSDK.MQTTLib import AWSIoTMQTTClient\n",
    "import logging\n",
    "import time\n",
    "import argparse\n",
    "import json"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 3,
   "metadata": {},
   "outputs": [],
   "source": [
    "# Custom MQTT message callback\n",
    "def customCallback(client, userdata, message):\n",
    "    print(\"Received a new message: \")\n",
    "    print(message.payload)\n",
    "    print(\"from topic: \")\n",
    "    print(message.topic)\n",
    "    print(\"--------------\\n\\n\")"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 4,
   "metadata": {},
   "outputs": [],
   "source": [
    "host = 'a2xqi9tklutvnu-ats.iot.us-west-2.amazonaws.com'\n",
    "rootCAPath = 'root-CA.crt'\n",
    "certificatePath = 'iot-beyoung-01.cert.pem'\n",
    "privateKeyPath = 'iot-beyoung-01.private.key'\n",
    "port = 8883\n",
    "clientId = 'basicPubSub'\n",
    "topic = 'iot/presigned_upload/result'"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 5,
   "metadata": {},
   "outputs": [],
   "source": [
    "# Configure logging\n",
    "# logger = logging.getLogger(\"AWSIoTPythonSDK.core\")\n",
    "# logger.setLevel(logging.DEBUG)\n",
    "# streamHandler = logging.StreamHandler()\n",
    "# formatter = logging.Formatter('%(asctime)s - %(name)s - %(levelname)s - %(message)s')\n",
    "# streamHandler.setFormatter(formatter)\n",
    "# logger.addHandler(streamHandler)"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": 6,
   "metadata": {},
   "outputs": [
    {
     "name": "stdout",
     "output_type": "stream",
     "text": [
      "Received a new message: \n",
      "b'{\"url\": \"https://beyoung-pb-upload-download.s3.amazonaws.com/\", \"fields\": {\"key\": \"iot-devices/bear-01.jpg\", \"AWSAccessKeyId\": \"ASIAW5ZABL77YHBUVRMD\", \"x-amz-security-token\": \"IQoJb3JpZ2luX2VjEE8aCXVzLXdlc3QtMiJHMEUCIQD7RU1lHebNI4oDCezuldxdRf02/jzOaxmS1XSZ6CYzlAIgPVqXcPGiL5N319gBQSS7LisPIdQChYddtylvY0oBpsQq0gEIeBABGgw0NzYyNzE2OTc5MTkiDLf4+Uh1YHW8K3vfqyqvAfkEtbaeh68e8BMREsYQun16WeUTaX1J37CurmQnc6/Ir4dWvBsF9US2PlZbBNI9pm6lpT1hsapNG/y4q5rm1pOcyDE/29+81pg5Rcp8zWh/uBJj6b1CPn52yNmTYYpFx34MmOcTQcvoFyAACkfZy0SurXpLzLlsDbTmULNMloR5/sDj6vR5bgjIgrsebf/egE6AkYkfSNkn+xRptKVoUUVcSkJ4d+htFPOmMQXK3/Mw14OM9QU64AFjBgovyRD7iyeLhBa1e5kysPyKjjMIhCRhLgQXSyLyVK0PriB0f3iKUl1N1+v4wCDSVaqWskm1cZDRzGr+BboeacSR7MA5XECWlgs1vgMjV7oMcjmLzyOMP1tSLsbAeFKdItbz5V71ZWPdJu43WPzdO7iyZFD/qwCcc6daFpZmgJpoLvoknzr/QIhZ7Gf9NiemaCFUB0cldWRD9meh8x9W3ZCEd8eLBBxusLsvPPusPFMqTP5Bi3tzsUFaNhX38z992FFVVylW8RqUxTDamslnw0Wt5IKEFWsYQF/kJUx3Mg==\", \"policy\": \"eyJleHBpcmF0aW9uIjogIjIwMjAtMDQtMjRUMTU6Mzk6MTZaIiwgImNvbmRpdGlvbnMiOiBbeyJidWNrZXQiOiAiYmV5b3VuZy1wYi11cGxvYWQtZG93bmxvYWQifSwgeyJrZXkiOiAiaW90LWRldmljZXMvYmVhci0wMS5qcGcifSwgeyJ4LWFtei1zZWN1cml0eS10b2tlbiI6ICJJUW9KYjNKcFoybHVYMlZqRUU4YUNYVnpMWGRsYzNRdE1pSkhNRVVDSVFEN1JVMWxIZWJOSTRvRENlenVsZHhkUmYwMi9qek9heG1TMVhTWjZDWXpsQUlnUFZxWGNQR2lMNU4zMTlnQlFTUzdMaXNQSWRRQ2hZZGR0eWx2WTBvQnBzUXEwZ0VJZUJBQkdndzBOell5TnpFMk9UYzVNVGtpRExmNCtVaDFZSFc4SzN2ZnF5cXZBZmtFdGJhZWg2OGU4Qk1SRXNZUXVuMTZXZVVUYVgxSjM3Q3VybVFuYzYvSXI0ZFd2QnNGOVVTMlBsWmJCTkk5cG02bHBUMWhzYXBORy95NHE1cm0xcE9jeURFLzI5KzgxcGc1UmNwOHpXaC91QkpqNmIxQ1BuNTJ5Tm1UWVlwRngzNE1tT2NUUWN2b0Z5QUFDa2ZaeTBTdXJYcEx6TGxzRGJUbVVMTk1sb1I1L3NEajZ2UjViZ2pJZ3JzZWJmL2VnRTZBa1lrZlNOa24reFJwdEtWb1VVVmNTa0o0ZCtodEZQT21NUVhLMy9NdzE0T005UVU2NEFGakJnb3Z5UkQ3aXllTGhCYTFlNWt5c1B5S2pqTUloQ1JoTGdRWFN5THlWSzBQcmlCMGYzaUtVbDFOMSt2NHdDRFNWYXFXc2ttMWNaRFJ6R3IrQmJvZWFjU1I3TUE1WEVDV2xnczF2Z01qVjdvTWNqbUx6eU9NUDF0U0xzYkFlRktkSXRiejVWNzFaV1BkSnU0M1dQemRPN2l5WkZEL3F3Q2NjNmRhRnBabWdKcG9Mdm9rbnpyL1FJaFo3R2Y5TmllbWFDRlVCMGNsZFdSRDltZWg4eDlXM1pDRWQ4ZUxCQnh1c0xzdlBQdXNQRk1xVFA1QmkzdHpzVUZhTmhYMzh6OTkyRkZWVnlsVzhScVV4VERhbXNsbncwV3Q1SUtFRldzWVFGL2tKVXgzTWc9PSJ9XX0=\", \"signature\": \"ldEpjBv9kbqnU9pcWczhwsaSX/Q=\"}}'\n",
      "from topic: \n",
      "iot/presigned_upload/result\n",
      "--------------\n",
      "\n",
      "\n"
     ]
    },
    {
     "ename": "KeyboardInterrupt",
     "evalue": "",
     "output_type": "error",
     "traceback": [
      "\u001b[0;31m---------------------------------------------------------------------------\u001b[0m",
      "\u001b[0;31mKeyboardInterrupt\u001b[0m                         Traceback (most recent call last)",
      "\u001b[0;32m<ipython-input-6-4c9688f21bb6>\u001b[0m in \u001b[0;36m<module>\u001b[0;34m()\u001b[0m\n\u001b[1;32m     18\u001b[0m \u001b[0;31m# loop forever\u001b[0m\u001b[0;34m\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[1;32m     19\u001b[0m \u001b[0;32mwhile\u001b[0m \u001b[0;32mTrue\u001b[0m\u001b[0;34m:\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[0;32m---> 20\u001b[0;31m     \u001b[0mtime\u001b[0m\u001b[0;34m.\u001b[0m\u001b[0msleep\u001b[0m\u001b[0;34m(\u001b[0m\u001b[0;36m1\u001b[0m\u001b[0;34m)\u001b[0m\u001b[0;34m\u001b[0m\u001b[0m\n\u001b[0m",
      "\u001b[0;31mKeyboardInterrupt\u001b[0m: "
     ]
    }
   ],
   "source": [
    "# Init AWSIoTMQTTClient\n",
    "myAWSIoTMQTTClient = None\n",
    "myAWSIoTMQTTClient = AWSIoTMQTTClient(clientId)\n",
    "myAWSIoTMQTTClient.configureEndpoint(host, port)\n",
    "myAWSIoTMQTTClient.configureCredentials(rootCAPath, privateKeyPath, certificatePath)\n",
    "\n",
    "# AWSIoTMQTTClient connection configuration\n",
    "myAWSIoTMQTTClient.configureAutoReconnectBackoffTime(1, 32, 20)\n",
    "myAWSIoTMQTTClient.configureOfflinePublishQueueing(-1)  # Infinite offline Publish queueing\n",
    "myAWSIoTMQTTClient.configureDrainingFrequency(2)  # Draining: 2 Hz\n",
    "myAWSIoTMQTTClient.configureConnectDisconnectTimeout(10)  # 10 sec\n",
    "myAWSIoTMQTTClient.configureMQTTOperationTimeout(5)  # 5 sec\n",
    "\n",
    "# Connect and subscribe to AWS IoT\n",
    "myAWSIoTMQTTClient.connect()\n",
    "myAWSIoTMQTTClient.subscribe(topic, 0, customCallback)\n",
    "\n",
    "# loop forever\n",
    "while True:\n",
    "    time.sleep(1)"
   ]
  },
  {
   "cell_type": "markdown",
   "metadata": {},
   "source": [
    "# Go to AWS IoT Console\n",
    "\n",
    "* publish topic:\n",
    "\n",
    "**iot/presigned_upload**\n",
    "\n",
    "```\n",
    "{\n",
    "  \"bucket\": \"beyoung-pb-upload-download\",\n",
    "  \"prefix\": \"iot-devices\",\n",
    "  \"name\": \"bear-01.jpg\",\n",
    "  \"expiration\": 300\n",
    "}\n",
    "```"
   ]
  },
  {
   "cell_type": "code",
   "execution_count": null,
   "metadata": {},
   "outputs": [],
   "source": []
  }
 ],
 "metadata": {
  "kernelspec": {
   "display_name": "conda_python3",
   "language": "python",
   "name": "conda_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.5"
  }
 },
 "nbformat": 4,
 "nbformat_minor": 4
}