first commit

Author: amatur

Dispatcher.py

@@ -0,0 +1,62 @@
+import time
+from my_libs import *
+import heapq;
+import random;
+import Queue;
+import json
+
+setup_logging()
+log = logging.getLogger("<Sensor>")
+
+
+class Callable():
+    def call(sim):
+        raise Exception('Call of %s is not implemented' % self)
+
+class Sensor(Callable):
+
+    def __init__(self, name, readlatency, period, size, gamma):
+        """
+        Construct a new 'Sensor' object.
+        :param name: The name of Sensor
+        :param readlatency: read latency
+        :param period: The period to read
+        :param size: The size of sensor reading in bytes
+        :return: returns nothing
+        """
+        self.name = name
+        self.readlatency = readlatency
+        self.period = period
+        self.size = size
+        self.gamma = gamma
+        self.flag = False
+
+    def __repr__(self):
+        return 'Sensor::%s' % self.name
+
+    def set_period(self, period):
+        self.period = period
+
+    def call(self, sim):
+        if self.flag:
+            self.flag = False
+            print 'Time %f sensor %s reading completed' % (sim.simclock, self)
+            sim.add_event(sim.simclock + self.period, self)
+        else:
+            self.flag = True
+            sim.read_queue = sim.read_queue + self.size
+            reading = Reading(self.name, sim.simclock, self.size)
+            sim.readings_queue.put(reading)
+            print 'Time %f reading sensor %s current queue %d' % (sim.simclock, self, sim.read_queue)
+            sim.add_event(sim.simclock + self.readlatency, self)
+
+
+
+class Reading:
+    def __init__(self, sensor_name, sensing_time, size):
+        self.sensor_name = sensor_name
+        self.sensing_time = sensing_time
+        self.size = size
+
+    def __repr__(self):
+        return 'Sensor::%s' % self.sensor_name

Sensor.py

@@ -0,0 +1,15 @@
+import time
+import picamera
+
+def take_picture(pic_name='image.jpg', delay=0):
+    #pic_location = '/home/pi/workshop/camera/'
+    pic_location = 'pictures/'
+    pic_location = pic_location + pic_name
+    with picamera.PiCamera() as camera:
+        camera.start_preview()
+        time.sleep(delay)
+        camera.capture(pic_location)
+        camera.stop_preview()
+
+#pic_location = '/home/pi/workshop/camera/image.jpg'
+#take_picture()

Sensor.pyc

@@ -0,0 +1 @@
+{"MQ6_RAW": 410, "MQ6": 2.943574073499083, "MQ135": 973.5719237041191, "MQ4": 1.574462293197566, "DUST_RAW": 189.98, "DUST": 10204.00390625, "MQ4_RAW": 278, "MQ135_RAW": 324}

cam.py

@@ -0,0 +1 @@
+{"SENSE_INTERVAL": 10, "TX_MEDIUM": "wlan0", "MQTT_BROKER_HOSTNAME": "iot.eclipse.org", "RUNTIME": 86400}

cam.pyc

@@ -0,0 +1,51 @@
+{
+    "version": 1,
+    "disable_existing_loggers": false,
+    "formatters": {
+        "simple": {
+            "format": "%(asctime)s \t %(name)s \t %(levelname)s \t %(message)s"
+        }
+    },
+
+    "handlers": {
+        "console": {
+            "class": "logging.StreamHandler",
+            "level": "CRITICAL",
+            "formatter": "simple",
+            "stream": "ext://sys.stdout"
+        },
+
+        "bytes_file_handler": {
+            "class": "logging.handlers.RotatingFileHandler",
+            "level": 45,
+            "formatter": "simple",
+            "filename": "logs/bytes.log",
+            "maxBytes": 512000,
+            "backupCount": 20,
+            "encoding": "utf8"
+        },
+
+        "error_file_handler": {
+            "class": "logging.handlers.RotatingFileHandler",
+            "level": "INFO",
+            "formatter": "simple",
+            "filename": "logs/event_log.log",
+            "maxBytes": 512000,
+            "backupCount": 20,
+            "encoding": "utf8"
+        }
+    },
+
+    "loggers": {
+        "my_module": {
+            "level": "ERROR",
+            "handlers": ["console"],
+            "propagate": "no"
+        }
+    },
+
+    "root": {
+        "level": "INFO",
+        "handlers": ["console", "bytes_file_handler", "error_file_handler"]
+    }
+}