'Send an event message for publishing
:param events: events from pipeline after transformation'

def publish_events(self, events):

    if self.raw_only:
        data = [evt.as_dict()['raw']['payload'] for evt in events if evt.as_dict().get('raw', {}).get('payload')]
    else:
        data = [event.serialize() for event in events]
    self.poster(data)
