optimized report template

Author: hANSIc99

examples/logging_and_report/generic_pipe_2f78d74c.py

@@ -12,28 +12,13 @@ def __init__(self, id, config, inputData, return_queue, cmd_queue):
 
  def execute(self):
 
+ output = None
+ if self.inputData == '5m':
+ t0 = int(time.time()) # get current unix time
+ t1 = t0 - (60 * 5) # calculate unix stamp time 5 minutes ago
 
- #####################################
- # #
- # REFERENCE IMPLEMENTATION #
- # #
- #####################################
+ output = 'SELECT * FROM my_table WHERE timestamp BETWEEN {} AND {}'.format(t1, t0)
 
 
-
- if self.inputData is None:
- output = 0
- else:
- output = self.inputData + 1
-
-
- 
- #########################################
- # #
- # The execution exits immediately #
- # after providing output data #
- # #
- #########################################
-
- recordDone = Record(output, 'Sending value of cnt: {}'.format(output)) 
+ recordDone = Record(output) 
  self.return_queue.put(recordDone)