Create threading program with Google API

Author: arifulhaqueuc

script_19.py

@@ -0,0 +1,48 @@
+import requests
+from multiprocessing.dummy import Pool
+import time
+from datadiff import diff
+ 
+def getzip(code):
+    try:
+        code = str(code)
+        url = "https://maps.googleapis.com/maps/api/geocode/json?address={}".format(code)
+        res = requests.get(url).json()['results']
+        if len(res) < 1: # Re-try
+            print "Retrying"
+            return getzip(code)
+        iszip = 'postal_code' in res[0]['types'] and "United States" in str(res[0]['address_components'])
+    except Exception as e:
+        print "In error"
+        print e
+        iszip = False
+    return (code, iszip)
+ziprange = range(94400, 94420)
+print "Range is: " + str(len(ziprange))
+ 
+print "Using one thread"
+start = time.time()
+syncres = [getzip(c) for c in ziprange] 
+print "took " + str(time.time() - start)
+ 
+print "Using multiple threads"
+start = time.time()
+ 
+# Magic
+pool = Pool(10)
+asyncres = pool.map(getzip, ziprange)
+pool.close()
+pool.join()
+asyncres = sorted(asyncres)
+# End of Magic
+ 
+print "took " + str(time.time() - start)
+ 
+# Make sure results are equal
+d = diff(syncres, asyncres)
+if len(d.diffs) > 0:
+    print "diff is"
+    print d
+ 
+for r in asyncres:
+    print "Zip code {} is {} US code".format(r[0], "valid" if r[1] else "invalid")