Updated notebooks

Author: matthew-mcateer

1_start/.ipynb_checkpoints/First Twitter App-checkpoint.ipynb

@@ -21,8 +21,8 @@ def __init__(self, csocket):
   def on_data(self, data):
       try:
           msg = json.loads( data )
-          print( msg['text'].encode('utf-8') )
-          self.client_socket.send( msg['text'].encode('utf-8') )
+          print(msg['text'].encode('utf-8'))
+          self.client_socket.send( msg['text'].encode('utf-8'))
           return True
       except BaseException as e:
           print("Error on_data: %s" % str(e))
@@ -40,7 +40,7 @@ def sendData(c_socket):
   twitter_stream.filter(track=['football'])
 
 if __name__ == "__main__":
-  s = socket.socket()         # Create a socket object
+  s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)         # Create a socket object
   host = "127.0.0.1"     # Get local machine name
   port = 5555                 # Reserve a port for your service.
   s.bind((host, port))        # Bind to the port
@@ -50,6 +50,6 @@ def sendData(c_socket):
   s.listen(5)                 # Now wait for client connection.
   c, addr = s.accept()        # Establish connection with client.
 
-  print( "Received request from: " + str( addr ) )
+  print("Received request from: " + str(addr))
 
-  sendData( c )
+  sendData(c)

1_start/First Twitter App.ipynb

@@ -48,11 +48,98 @@
   },
   {
    "cell_type": "code",
-   "execution_count": null,
-   "metadata": {
-    "collapsed": true
-   },
-   "outputs": [],
+   "execution_count": 3,
+   "metadata": {},
+   "outputs": [
+    {
+     "name": "stdout",
+     "output_type": "stream",
+     "text": [
+      "-------------------------------------------\n",
+      "Time: 2018-01-17 17:16:21\n",
+      "-------------------------------------------\n",
+      "(0, 100)\n",
+      "(8, 100)\n",
+      "(2, 100)\n",
+      "(4, 100)\n",
+      "(6, 100)\n",
+      "(1, 100)\n",
+      "(3, 100)\n",
+      "(9, 100)\n",
+      "(5, 100)\n",
+      "(7, 100)\n",
+      "\n",
+      "-------------------------------------------\n",
+      "Time: 2018-01-17 17:16:22\n",
+      "-------------------------------------------\n",
+      "(0, 100)\n",
+      "(8, 100)\n",
+      "(2, 100)\n",
+      "(4, 100)\n",
+      "(6, 100)\n",
+      "(1, 100)\n",
+      "(3, 100)\n",
+      "(9, 100)\n",
+      "(5, 100)\n",
+      "(7, 100)\n",
+      "\n",
+      "-------------------------------------------\n",
+      "Time: 2018-01-17 17:16:23\n",
+      "-------------------------------------------\n",
+      "(0, 100)\n",
+      "(8, 100)\n",
+      "(2, 100)\n",
+      "(4, 100)\n",
+      "(6, 100)\n",
+      "(1, 100)\n",
+      "(3, 100)\n",
+      "(9, 100)\n",
+      "(5, 100)\n",
+      "(7, 100)\n",
+      "\n",
+      "-------------------------------------------\n",
+      "Time: 2018-01-17 17:16:24\n",
+      "-------------------------------------------\n",
+      "(0, 100)\n",
+      "(8, 100)\n",
+      "(2, 100)\n",
+      "(4, 100)\n",
+      "(6, 100)\n",
+      "(1, 100)\n",
+      "(3, 100)\n",
+      "(9, 100)\n",
+      "(5, 100)\n",
+      "(7, 100)\n",
+      "\n",
+      "-------------------------------------------\n",
+      "Time: 2018-01-17 17:16:25\n",
+      "-------------------------------------------\n",
+      "(0, 100)\n",
+      "(8, 100)\n",
+      "(2, 100)\n",
+      "(4, 100)\n",
+      "(6, 100)\n",
+      "(1, 100)\n",
+      "(3, 100)\n",
+      "(9, 100)\n",
+      "(5, 100)\n",
+      "(7, 100)\n",
+      "\n",
+      "-------------------------------------------\n",
+      "Time: 2018-01-17 17:16:26\n",
+      "-------------------------------------------\n",
+      "\n",
+      "-------------------------------------------\n",
+      "Time: 2018-01-17 17:16:27\n",
+      "-------------------------------------------\n",
+      "\n",
+      "-------------------------------------------\n",
+      "Time: 2018-01-17 17:16:28\n",
+      "-------------------------------------------\n",
+      "\n"
+     ]
+    }
+   ],
    "source": [
     "if __name__ == \"__main__\":\n",
     "    sc = SparkContext(appName=\"PythonStreamingQueueStream\")\n",