WIP

Author: rishiraj88

Diff for: JupyterNotebooks/kafkatwitterstreaming.ipynb

@@ -0,0 +1,88 @@
+{
+ "cells": [
+  {
+   "cell_type": "code",
+   "execution_count": null,
+   "metadata": {},
+   "outputs": [],
+   "source": [
+    "from tweepy.streaming import StreamListener\n",
+    "from tweepy import OAuthHandler\n",
+    "from tweepy import Stream\n",
+    "from kafka import SimpleProducer, KafkaClient\n",
+    "import time\n",
+    "\n",
+    "access_token = \"748200460067045376-zYxRRyxiPIywcw2IV50IQiIxzQVN5FZ\"\n",
+    "access_token_secret =  \"c6dRkeRbgPqtbWAOTz0OfOMpBvhZS6KqWFjtEqHBEv7me\"\n",
+    "consumer_key =  \"ukUrCrJdd6MQQd0HQBzCDwcLq\"\n",
+    "consumer_secret =  \"VCf2wU1MhedUFnQeCwffzstdVkF7rbURzoNNDAdPPvbWfDtggP\"\n",
+    "kafka_endpoint = \"ip-20-0-32-4.ap-south-1.compute.internal:9092\"\n",
+    "kafka_topic = \"rk_hadoop\"\n",
+    "twitter_hash_tag = \"RamNavami\"\n",
+    "time_limit = 10\n",
+    "\n",
+    "class StdOutListener(StreamListener):\n",
+    "\tdef __init__(self, time_limit=time_limit):\n",
+    "\t\tself.start_time = time.time()\n",
+    "\t\tself.limit = time_limit\n",
+    "\t\tsuper(StdOutListener, self).__init__()\n",
+    "\tdef on_data(self, data):\n",
+    "\t\tif (time.time() - self.start_time) < self.limit:\n",
+    "            #msg = json.loads(data)\n",
+    "\t\t\tproducer.send_messages(kafka_topic, data.encode('utf-8'))\n",
+    "\t\t\tprint (data)\n",
+    "\t\t\treturn True\n",
+    "\t\texit(0)\n",
+    "\tdef on_error(self, status):\n",
+    "\t\tprint (status)\n",
+    "\n",
+    "kafka = KafkaClient(kafka_endpoint)\n",
+    "producer = SimpleProducer(kafka)\n",
+    "l = StdOutListener()\n",
+    "auth = OAuthHandler(consumer_key, consumer_secret)\n",
+    "auth.set_access_token(access_token, access_token_secret)\n",
+    "stream = Stream(auth, l)\n",
+    "stream.filter(track=twitter_hash_tag)\n"
+   ]
+  },
+  {
+   "cell_type": "code",
+   "execution_count": null,
+   "metadata": {
+    "collapsed": true
+   },
+   "outputs": [],
+   "source": []
+  },
+  {
+   "cell_type": "code",
+   "execution_count": null,
+   "metadata": {
+    "collapsed": true
+   },
+   "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.3"
+  }
+ },
+ "nbformat": 4,
+ "nbformat_minor": 2
+}

Diff for: Python101/factorial.py

@@ -25,4 +25,15 @@ def fact(a):
 num = int(input("Enter a number to get the factorial of: "))
 factorial = fact(num)
 print("The factorial of",num,"is:",factorial)
-# method 2 (using recursion) - end
+# method 2 (using recursion) - end
+
+# method 3 - start
+def factorial(num):
+    if "int" not in str(type(num)):
+        return None
+    if num == 0:
+        return 1
+    elif num > 0:
+        return int(num) * factorial(num-1)
+    return None
+# method 3 - end