Fixed examples after running them by hand.

Some got missed. Reran them and fixed them all.

Author: Frederick Ross

examples/abc/b.py

@@ -14,6 +14,9 @@
 
 """Retrieves a list of installed apps from Splunk using the binding module."""
 
+import sys, os
+sys.path.insert(0, os.path.join(os.path.dirname(__file__), "..", ".."))
+
 from xml.etree import ElementTree
 
 import splunklib.binding as binding

examples/abc/c.py

@@ -13,6 +13,8 @@
 # under the License.
 
 """Retrieves a list of installed apps from Splunk using the client module."""
+import sys, os
+sys.path.insert(0, os.path.join(os.path.dirname(__file__), "..", ".."))
 
 import splunklib.client as client
 

examples/dashboard/feed.py

@@ -60,14 +60,14 @@ def iterate(job):
         reader = results.ResultsReader(job.preview())
         data = []
 
-        for kind,result in reader:
-            if kind == results.RESULT:
+        for result in reader:
+            if isinstance(result, dict):
                 status_source_xml = result["status_source"].strip()
                 source = status_source_xml
-                if (status_source_xml.startswith("<a")):
+                if status_source_xml.startswith("<a"):
                     try:
                         source = ElementTree.XML(status_source_xml).text
-                    except:
+                    except Exception, e:
                         print status_source_xml
                         raise e
 
@@ -78,7 +78,7 @@ def iterate(job):
 
         send_data(access_key = leftronic_access_key, stream_name = "top_sources", point = { "leaderboard": data })
 
-    return (created_job, lambda job: iterate(job))
+    return created_job, lambda job: iterate(job)
 
 def geo(service):
     query = "search index=twitter coordinates_type=Point coordinates_coordinates=* | fields coordinates_coordinates"
@@ -87,8 +87,8 @@ def geo(service):
     def iterate(job):
         reader = results.ResultsReader(job.preview())
         points = []
-        for kind,result in reader:
-            if kind == results.RESULT:
+        for result in reader:
+            if isinstance(result, dict):
                 lng, lat = result["coordinates_coordinates"].split(",")
                 point = {
                     "latitude": lat,
@@ -100,16 +100,16 @@ def iterate(job):
         send_data(access_key = leftronic_access_key, stream_name = "geo", command = "clear")
         send_data(access_key = leftronic_access_key, stream_name = "geo", point = points)
 
-    return (created_job, lambda job: iterate(job))
+    return created_job, lambda job: iterate(job)
 
 def tweets(service):
     query = "search index=twitter | head 15 | fields user_name, user_screen_name, text, user_profile_image_url "
     created_job = service.jobs.create(query, search_mode="realtime", earliest_time="rt-5m", latest_time="rt")
 
     def iterate(job):
         reader = results.ResultsReader(job.preview())
-        for kind,result in reader:
-            if kind == results.RESULT:
+        for result in reader:
+            if isinstance(result, dict):
                 user = result.get("user_name", result.get("user_screen_name", ""))
                 text = result.get("text", "")
                 img = result.get("user_profile_image_url", "")
@@ -121,16 +121,16 @@ def iterate(job):
 
                 send_data(access_key = leftronic_access_key, stream_name = "tweets", point = point)
 
-    return (created_job, lambda job: iterate(job))
+    return created_job, lambda job: iterate(job)
 
 def counts(service):    
     query = "search index=twitter | stats count by user_id | fields user_id, count | stats count(user_id) as user_count, sum(count) as tweet_count"
     created_job = service.jobs.create(query, search_mode="realtime", earliest_time="rt-5m", latest_time="rt")
 
     def iterate(job):
         reader = results.ResultsReader(job.preview())
-        for kind,result in reader:
-            if kind == results.RESULT:
+        for result in reader:
+            if isinstance(result, dict):
                 user_count = result["user_count"]
                 tweet_count = result.get("tweet_count", 0)
 
@@ -142,7 +142,7 @@ def iterate(job):
                 point = int(tweet_count)
                 send_data(access_key = leftronic_access_key, stream_name = "tweets_count_5m", point = point)
 
-    return (created_job, lambda job: iterate(job))
+    return created_job, lambda job: iterate(job)
 
 def top_tags(service):
     query = 'search index=twitter text=* | rex field=text max_match=1000 "#(?<tag>\w{1,})" | fields tag | mvexpand tag | top 5 tag'
@@ -152,8 +152,8 @@ def iterate(job):
         reader = results.ResultsReader(job.preview())
         data = []
 
-        for kind,result in reader:
-            if kind == results.RESULT:
+        for result in reader:
+            if isinstance(result, dict):
                 tag = result["tag"]
                 count = result["count"]
 
@@ -164,7 +164,7 @@ def iterate(job):
 
         send_data(access_key = leftronic_access_key, stream_name = "top_tags", point = { "leaderboard": data })
 
-    return (created_job, lambda job: iterate(job))
+    return created_job, lambda job: iterate(job)
 
 def main(argv):
     # Parse the command line args.

examples/twitted/input.py

@@ -254,12 +254,12 @@ def main():
 
     # Create the TCP input if it doesn't exist
     input_host = kwargs.get("inputhost", DEFAULT_SPLUNK_HOST)
-    input_port = int(kwargs.get("inputport", DEFAULT_SPLUNK_PORT))
+    input_port = kwargs.get("inputport", DEFAULT_SPLUNK_PORT)
     input_name = str(input_port)
     if input_name not in service.inputs:
         if verbose > 0: print "Creating input '%s'" % input_name
         service.inputs.create(
-            "tcp", input_port, index="twitter", sourcetype="twitter")
+            input_port, "tcp", index="twitter", sourcetype="twitter")
 
     global ingest
     ingest = socket.socket(socket.AF_INET, socket.SOCK_STREAM)