Add Python 3.3+ and Windows support

examples/apparent_temperature/apparent_temperature/heat_index_calculator.py

@@ -4,6 +4,8 @@
 from collections import defaultdict
 import logging
 import time
+import os
+import tempfile
 
 from pyleus.storm import SimpleBolt
 
@@ -74,7 +76,8 @@ def process_tuple(self, tup):
 if __name__ == '__main__':
     logging.basicConfig(
         level=logging.DEBUG,
-        filename='/tmp/apparent_temperature_heat_index.log',
+        filename=os.path.join(tempfile.gettempdir(),
+                              'apparent_temperature_heat_index.log'),
         filemode='a',
     )
 

examples/apparent_temperature/apparent_temperature/humidity_generator.py

@@ -4,6 +4,8 @@
 
 from collections import namedtuple
 import random
+import os
+import tempfile
 
 from apparent_temperature.measure_generator import MeasureGeneratorSpout
 
@@ -45,7 +47,8 @@ def log(self, measure):
 if __name__ == '__main__':
     logging.basicConfig(
         level=logging.DEBUG,
-        filename='/tmp/apparent_temperature_humidity.log',
+        filename=os.path.join(tempfile.gettempdir(),
+                              'apparent_temperature_humidity.log'),
         filemode='a',
     )
 

examples/apparent_temperature/apparent_temperature/temperature_generator.py

@@ -4,6 +4,8 @@
 
 from collections import namedtuple
 import random
+import os
+import tempfile
 
 from apparent_temperature.measure_generator import MeasureGeneratorSpout
 
@@ -45,7 +47,8 @@ def log(self, measure):
 if __name__ == '__main__':
     logging.basicConfig(
         level=logging.DEBUG,
-        filename='/tmp/apparent_temperature_temperature.log',
+        filename=os.path.join(tempfile.gettempdir(),
+                              'apparent_temperature_temperature.log'),
         filemode='a',
     )
 

examples/apparent_temperature/apparent_temperature/wind_chill_calculator.py

@@ -4,6 +4,8 @@
 from collections import defaultdict
 import logging
 import time
+import os
+import tempfile
 
 from pyleus.storm import SimpleBolt
 
@@ -59,7 +61,8 @@ def process_tuple(self, tup):
 if __name__ == '__main__':
     logging.basicConfig(
         level=logging.DEBUG,
-        filename='/tmp/apparent_temperature_wind_chill.log',
+        filename=os.path.join(tempfile.gettempdir(),
+                              'apparent_temperature_wind_chill.log'),
         filemode='a',
     )
 

examples/apparent_temperature/apparent_temperature/wind_speed_generator.py

@@ -4,6 +4,8 @@
 
 from collections import namedtuple
 import random
+import os
+import tempfile
 
 from apparent_temperature.measure_generator import MeasureGeneratorSpout
 
@@ -45,7 +47,8 @@ def log(self, measure):
 if __name__ == '__main__':
     logging.basicConfig(
         level=logging.DEBUG,
-        filename='/tmp/apparent_temperature_wind_speed.log',
+        filename=os.path.join(tempfile.gettempdir(),
+                              'apparent_temperature_wind_speed.log'),
         filemode='a',
     )
 

examples/bandwith_monitoring/bandwith_monitoring/access_log_generator.py

@@ -5,6 +5,8 @@
 from collections import namedtuple
 from random import choice
 import time
+import os
+import tempfile
 
 from pyleus.storm import Spout
 
@@ -13,7 +15,7 @@
 
 Request = namedtuple("Request", "ip_address request size")
 
-_dash_to_zero = lambda size: 0 if size == "-" else long(size)
+_dash_to_zero = lambda size: 0 if size == "-" else int(size)
 
 
 class AccessLogGeneratorSpout(Spout):
@@ -48,7 +50,8 @@ def next_tuple(self):
 if __name__ == '__main__':
     logging.basicConfig(
         level=logging.DEBUG,
-        filename='/tmp/bandwith_monitoring_access_log_generator.log',
+        filename=os.path.join(tempfile.gettempdir(),
+                              'bandwith_monitoring_access_log_generator.log'),
         filemode='a',
     )
 

examples/bandwith_monitoring/bandwith_monitoring/traffic_aggregator.py

@@ -4,6 +4,8 @@
 import logging
 from collections import defaultdict
 from collections import namedtuple
+import os
+import tempfile
 
 from pyleus.storm import SimpleBolt
 from bandwith_monitoring.access_log_generator import Request
@@ -71,7 +73,8 @@ def advance_window(self):
 if __name__ == '__main__':
     logging.basicConfig(
         level=logging.DEBUG,
-        filename='/tmp/bandwith_monitoring_traffic_aggregator.log',
+        filename=os.path.join(tempfile.gettempdir(),
+                              'bandwith_monitoring_traffic_aggregator.log'),
         filemode='a',
     )
 

examples/bandwith_monitoring/bandwith_monitoring/traffic_monitor.py

@@ -2,6 +2,9 @@
 
 import logging
 import time
+import os
+import tempfile
+
 from pyleus.storm import SimpleBolt
 from bandwith_monitoring.traffic_aggregator import Traffic
 
@@ -28,7 +31,8 @@ def process_tuple(self, tup):
 if __name__ == '__main__':
     logging.basicConfig(
         level=logging.DEBUG,
-        filename='/tmp/bandwith_monitoring_traffic_monitor.log',
+        filename=os.path.join(tempfile.gettempdir(),
+                              'bandwith_monitoring_traffic_monitor.log'),
         filemode='a',
     )
 

examples/exclamation_topology/exclamation_topology/exclamation_bolt.py

@@ -1,6 +1,8 @@
 from __future__ import absolute_import
 
 import logging
+import os
+import tempfile
 
 from pyleus.storm import SimpleBolt
 
@@ -27,7 +29,8 @@ def process_tuple(self, tup):
 if __name__ == '__main__':
     logging.basicConfig(
         level=logging.DEBUG,
-        filename='/tmp/exclamation_bolt.log',
+        filename=os.path.join(tempfile.gettempdir(),
+                              'exclamation_bolt.log'),
         filemode='a',
     )
 

examples/exclamation_topology/exclamation_topology/test_word_spout.py

@@ -4,6 +4,8 @@
 
 import random
 import time
+import os
+import tempfile
 
 from pyleus.storm import Spout
 
@@ -27,7 +29,8 @@ def next_tuple(self):
 if __name__ == '__main__':
     logging.basicConfig(
         level=logging.DEBUG,
-        filename='/tmp/exclamation_spout.log',
+        filename=os.path.join(tempfile.gettempdir(),
+                              'exclamation_spout.log'),
         filemode='a',
     )
 

examples/micro/micro/converter_bolt.py

@@ -1,4 +1,6 @@
 import logging
+import os
+import tempfile
 
 from pyleus.storm import SimpleBolt
 
@@ -44,7 +46,8 @@ def process_tuple(self, tup):
 if __name__ == '__main__':
     logging.basicConfig(
         level=logging.DEBUG,
-        filename='/tmp/micro_conversions.log',
+        filename=os.path.join(tempfile.gettempdir(),
+                              'micro_conversions.log'),
         format="%(message)s",
         filemode='a',
     )

examples/micro/micro/earnings_bolt.py

@@ -1,4 +1,6 @@
 import logging
+import os
+import tempfile
 
 from pyleus.storm import SimpleBolt
 
@@ -29,7 +31,8 @@ def process_tuple(self, tup):
 if __name__ == '__main__':
     logging.basicConfig(
         level=logging.DEBUG,
-        filename='/tmp/micro_earnings.log',
+        filename=os.path.join(tempfile.gettempdir(),
+                              'micro_earnings.log'),
         format="%(message)s",
         filemode='a',
     )

examples/micro/micro/micro_generator.py

@@ -1,6 +1,8 @@
 import logging
 import random
 import time
+import os
+import tempfile
 
 from pyleus.storm import Spout
 
@@ -33,7 +35,8 @@ def next_tuple(self):
 if __name__ == '__main__':
     logging.basicConfig(
         level=logging.DEBUG,
-        filename='/tmp/micro_microtransactions.log',
+        filename=os.path.join(tempfile.gettempdir(),
+                              'micro_microtransactions.log'),
         format="%(message)s",
         filemode='a',
     )

examples/micro/micro/rates_generator.py

@@ -2,6 +2,8 @@
 import logging
 import random
 import time
+import os
+import tempfile
 
 from pyleus.storm import Spout
 
@@ -28,7 +30,8 @@ def next_tuple(self):
 if __name__ == '__main__':
     logging.basicConfig(
         level=logging.DEBUG,
-        filename='/tmp/micro_exchange_rates.log',
+        filename=os.path.join(tempfile.gettempdir(),
+                              'micro_exchange_rates.log'),
         format="%(message)s",
         filemode='a',
     )

examples/top_urls/top_urls/fields.py

@@ -1,5 +1,7 @@
 from collections import namedtuple
 import logging
+import os
+import tempfile
 
 from pyleus.json_fields_bolt import JSONFieldsBolt
 
@@ -27,7 +29,8 @@ def extract_fields(self, json_dict):
 if __name__ == '__main__':
     logging.basicConfig(
         level=logging.DEBUG,
-        filename='/tmp/top_urls_fields.log',
+        filename=os.path.join(tempfile.gettempdir(),
+                              'top_urls_fields.log'),
         filemode='a',
     )
 

examples/top_urls/top_urls/log_top.py

@@ -2,6 +2,8 @@
 
 import datetime
 import logging
+import os
+import tempfile
 
 from pyleus.storm import SimpleBolt
 
@@ -20,7 +22,8 @@ def process_tuple(self, tup):
 if __name__ == '__main__':
     logging.basicConfig(
         level=logging.DEBUG,
-        filename='/tmp/top_urls_result.log',
+        filename=os.path.join(tempfile.gettempdir(),
+                              'top_urls_result.log'),
         filemode='a',
     )
 

examples/top_urls/top_urls/requests_generator.py

@@ -1,6 +1,8 @@
 from __future__ import absolute_import
 
 import logging
+import os
+import tempfile
 
 from random import choice
 import time
@@ -58,7 +60,8 @@ def next_tuple(self):
 if __name__ == '__main__':
     logging.basicConfig(
         level=logging.DEBUG,
-        filename='/tmp/top_urls_requests_generator.log',
+        filename=os.path.join(tempfile.gettempdir(),
+                              'top_urls_requests_generator.log'),
         filemode='a',
     )
 

examples/top_urls/top_urls/top_global.py

@@ -2,6 +2,8 @@
 
 import logging
 from operator import itemgetter
+import os
+import tempfile
 
 from pyleus.storm import SimpleBolt
 
@@ -36,7 +38,8 @@ def process_tuple(self, tup):
 if __name__ == '__main__':
     logging.basicConfig(
         level=logging.DEBUG,
-        filename='/tmp/top_urls_top_global.log',
+        filename=os.path.join(tempfile.gettempdir(),
+                              'top_urls_top_global.log'),
         filemode='a',
     )
 

examples/top_urls/top_urls/top_intermediate.py

@@ -4,6 +4,8 @@
 import logging
 from operator import itemgetter
 import time
+import os
+import tempfile
 
 from pyleus.storm import SimpleBolt
 
@@ -64,7 +66,8 @@ def calculate_top_N(self):
 if __name__ == '__main__':
     logging.basicConfig(
         level=logging.DEBUG,
-        filename='/tmp/top_urls_top_intermediate.log',
+        filename=os.path.join(tempfile.gettempdir(),
+                              'top_urls_top_intermediate.log'),
         filemode='a',
     )
 

examples/word_count/word_count/count_words.py

@@ -1,6 +1,8 @@
 from collections import defaultdict
 from collections import namedtuple
 import logging
+import os
+import tempfile
 
 from pyleus.storm import SimpleBolt
 
@@ -26,7 +28,8 @@ def process_tuple(self, tup):
 if __name__ == '__main__':
     logging.basicConfig(
         level=logging.DEBUG,
-        filename='/tmp/word_count_count_words.log',
+        filename=os.path.join(tempfile.gettempdir(),
+                              'word_count_count_words.log'),
         format="%(message)s",
         filemode='a',
     )