Update examples to support Python 2.7.9+

Author: Shakeel Mohamed

examples/async/async.py

@@ -22,6 +22,7 @@
 
 import sys, os, datetime
 import urllib
+import ssl
 sys.path.insert(0, os.path.join(os.path.dirname(__file__), "..", ".."))
 
 import splunklib.binding as binding
@@ -171,7 +172,12 @@ def request(url, message, **kwargs):
     method = message.get("method", "GET")
 
     # Note that we do not support proxies in this example
-    opener = urllib2.build_opener()
+    # If running Python 2.7.9+, disable SSL certificate validation
+    if sys.version_info >= (2, 7, 9):
+        unverified_ssl_handler = urllib2.HTTPSHandler(context=ssl._create_unverified_context())
+        opener = urllib2.build_opener(unverified_ssl_handler)
+    else:
+        opener = urllib2.build_opener()
 
     # Unfortunately, we need to use the hack of 
     # "overriding" `request.get_method` to specify
@@ -185,6 +191,7 @@ def request(url, message, **kwargs):
         response = opener.open(request)
     except Exception as e:
         response = e
+        print e
 
     # Normalize the response to something the SDK expects, and 
     # return it.

examples/handlers/handler_proxy.py

@@ -29,6 +29,7 @@
 from pprint import pprint
 from StringIO import StringIO
 import sys, os
+import ssl
 sys.path.insert(0, os.path.join(os.path.dirname(__file__), "..", ".."))
 import urllib2
 
@@ -52,9 +53,15 @@ def request(url, message, **kwargs):
     method = message['method'].lower()
     data = message.get('body', "") if method == 'post' else None
     headers = dict(message.get('headers', []))
-    context = urllib2.Request(url, data, headers)
+    req = urllib2.Request(url, data, headers)
     try:
-        response = urllib2.urlopen(context)
+        response = urllib2.urlopen(req)
+    except urllib2.URLError, response:
+        # If running Python 2.7.9+, disable SSL certificate validation and try again
+        if sys.version_info >= (2, 7, 9):
+            response = urllib2.urlopen(req, context=ssl._create_unverified_context())
+        else:
+            raise
     except urllib2.HTTPError, response:
         pass # Propagate HTTP errors via the returned response message
     return {

examples/handlers/handler_urllib2.py

@@ -21,6 +21,7 @@
 import sys, os
 sys.path.insert(0, os.path.join(os.path.dirname(__file__), "..", ".."))
 import urllib2
+import ssl
 
 import splunklib.client as client
 
@@ -34,9 +35,13 @@ def request(url, message, **kwargs):
     method = message['method'].lower()
     data = message.get('body', "") if method == 'post' else None
     headers = dict(message.get('headers', []))
-    context = urllib2.Request(url, data, headers)
+    # If running Python 2.7.9+, disable SSL certificate validation
+    req = urllib2.Request(url, data, headers)
     try:
-        response = urllib2.urlopen(context)
+        if sys.version_info >= (2, 7, 9):
+            response = urllib2.urlopen(req, context=ssl._create_unverified_context())
+        else:
+            response = urllib2.urlopen(req)
     except urllib2.HTTPError, response:
         pass # Propagate HTTP errors via the returned response message
     return {