| Total Complexity | 7 |
| Total Lines | 49 |
| Duplicated Lines | 0 % |
| Changes | 0 | ||
| 1 | from st2reactor.sensor.base import PollingSensor |
||
| 6 | class FibonacciSensor(PollingSensor): |
||
| 7 | |||
| 8 | def __init__(self, sensor_service, config, |
||
| 9 | poll_interval=5): |
||
| 10 | super(FibonacciSensor, self).__init__( |
||
| 11 | sensor_service=sensor_service, |
||
| 12 | config=config, |
||
| 13 | poll_interval=poll_interval |
||
| 14 | ) |
||
| 15 | self.a = None |
||
| 16 | self.b = None |
||
| 17 | self.count = None |
||
| 18 | self.logger = None |
||
| 19 | |||
| 20 | def setup(self): |
||
| 21 | self.a = 0 |
||
| 22 | self.b = 1 |
||
| 23 | self.count = 2 |
||
| 24 | self.logger = self.sensor_service.get_logger(name=self.__class__.__name__) |
||
| 25 | |||
| 26 | def poll(self): |
||
| 27 | fib = self.a + self.b |
||
| 28 | self.logger.debug('Count: %d, a: %d, b: %d', self.count, self.a, self.b) |
||
| 29 | |||
| 30 | payload = { |
||
| 31 | "count": self.count, |
||
| 32 | "fibonacci": fib, |
||
| 33 | "pythonpath": get_environ("PYTHONPATH") |
||
| 34 | } |
||
| 35 | |||
| 36 | self.sensor_service.dispatch(trigger="examples.fibonacci", payload=payload) |
||
| 37 | self.a = self.b |
||
| 38 | self.b = fib |
||
| 39 | self.count = self.count + 1 |
||
| 40 | |||
| 41 | def cleanup(self): |
||
| 42 | pass |
||
| 43 | |||
| 44 | def add_trigger(self, trigger): |
||
| 45 | # This method is called when trigger is created |
||
| 46 | pass |
||
| 47 | |||
| 48 | def update_trigger(self, trigger): |
||
| 49 | # This method is called when trigger is updated |
||
| 50 | pass |
||
| 51 | |||
| 52 | def remove_trigger(self, trigger): |
||
| 53 | # This method is called when trigger is deleted |
||
| 54 | pass |
||
| 55 |