def actionsiter(self):
for msg in self.queue.consume():<EOL><INDENT>try:<EOL><INDENT>for preproc in self.preprocessors:<EOL><INDENT>msg = preproc(msg)<EOL>if msg is None:<EOL><INDENT>break<EOL><DEDENT><DEDENT>if msg is None:<EOL><INDENT>continue<EOL><DEDENT>suffix = arrow.get(msg.get('<STR_LIT>')).strftime(self.suffix)<EOL>ts = parser.parse(msg.get('<STR_LIT>'))<EOL>ts = ts.replace(microsecond=<NUM_LIT:0>)<EOL>msg['<STR_LIT>'] = ts.isoformat()<EOL>if self.double_click_window > <NUM_LIT:0>:<EOL><INDENT>timestamp = mktime(utc.localize(ts).utctimetuple())<EOL>ts = ts.fromtimestamp(<EOL>timestamp // self.double_click_window *<EOL>self.double_click_window<EOL>)<EOL><DEDENT>yield dict(<EOL>_id=hash_id(ts.isoformat(), msg),<EOL>_op_type='<STR_LIT:index>',<EOL>_index='<STR_LIT>'.format(self.index, suffix),<EOL>_type=self.doctype,<EOL>_source=msg,<EOL>)<EOL><DEDENT>except Exception:<EOL><INDENT>current_app.logger.exception(u'<STR_LIT>')<EOL><DEDENT><DEDENT>
Iterator.