Skip to content

Commit

Permalink
Use sensor_service in examples
Browse files Browse the repository at this point in the history
  • Loading branch information
Lakshmi Kannan committed May 19, 2016
1 parent 8137e37 commit 5b937d5
Show file tree
Hide file tree
Showing 5 changed files with 10 additions and 10 deletions.
2 changes: 1 addition & 1 deletion contrib/default/sensors/README.md
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
# sensors

The sensors folder contains sensoros. See [Sensors](http://docs.stackstorm.com/sensors.html) for specifics on writing
The sensors folder contains sensors. See [Sensors](http://docs.stackstorm.com/sensors.html) for specifics on writing
sensors and registering TriggerTypes.
4 changes: 2 additions & 2 deletions contrib/examples/sensors/sample_polling_sensor.py
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,7 @@

class SamplePollingSensor(PollingSensor):
"""
* self._sensor_service
* self.sensor_service
- provides utilities like
get_logger() for writing to logs.
dispatch() for dispatching triggers into the system.
Expand All @@ -29,7 +29,7 @@ def poll(self):
# # _to_triggers is something you'd write to convert the data format you have
# # into a standard python dictionary. This should follow the payload schema
# # registered for the trigger.
# self._sensor_service.dispatch(trigger, payload)
# self.sensor_service.dispatch(trigger, payload)
# # You can refer to the trigger as dict
# # { "name": ${trigger_name}, "pack": ${trigger_pack} }
# # or just simply by reference as string.
Expand Down
4 changes: 2 additions & 2 deletions contrib/examples/sensors/sample_sensor.py
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,7 @@

class SampleSensor(Sensor):
"""
* self._sensor_service
* self.sensor_service
- provides utilities like
- get_logger() - returns logger instance specific to this sensor.
- dispatch() for dispatching triggers into the system.
Expand All @@ -24,7 +24,7 @@ def run(self):
# interacting with your external system, you'd inherit from PollingSensor.)
# For example, let's consider a simple flask app. You'd run the flask app here.
# You can dispatch triggers using sensor_service like so:
# self._sensor_service(trigger, payload, trace_tag)
# self.sensor_service(trigger, payload, trace_tag)
# # You can refer to the trigger as dict
# # { "name": ${trigger_name}, "pack": ${trigger_pack} }
# # or just simply by reference as string.
Expand Down
8 changes: 4 additions & 4 deletions contrib/hello-st2/sensors/sensor1.py
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@
class HelloSensor(Sensor):
def __init__(self, sensor_service, config):
super(HelloSensor, self).__init__(sensor_service=sensor_service, config=config)
self._logger = self._sensor_service.get_logger(name=self.__class__.__name__)
self._logger = self.sensor_service.get_logger(name=self.__class__.__name__)
self._stop = False

def setup(self):
Expand All @@ -15,10 +15,10 @@ def setup(self):
def run(self):
while not self._stop:
self._logger.debug('HelloSensor dispatching trigger...')
count = self._sensor_service.get_value('hello-st2.count') or 0
count = self.sensor_service.get_value('hello-st2.count') or 0
payload = {'greeting': 'Yo, StackStorm!', 'count': int(count) + 1}
self._sensor_service.dispatch(trigger='hello-st2.event1', payload=payload)
self._sensor_service.set_value('hello-st2.count', payload['count'])
self.sensor_service.dispatch(trigger='hello-st2.event1', payload=payload)
self.sensor_service.set_value('hello-st2.count', payload['count'])
eventlet.sleep(60)

def cleanup(self):
Expand Down
2 changes: 1 addition & 1 deletion contrib/linux/sensors/file_watch_sensor.py
Original file line number Diff line number Diff line change
Expand Up @@ -51,4 +51,4 @@ def _handle_line(self, file_path, line):
'file_name': os.path.basename(file_path),
'line': line
}
self._sensor_service.dispatch(trigger=trigger, payload=payload)
self.sensor_service.dispatch(trigger=trigger, payload=payload)

0 comments on commit 5b937d5

Please sign in to comment.