Untitled

                Never    
  @staticmethod
    def generate_file_name(event_name, event_type_prefix=None):
        if event_type_prefix is None:
            prefix = ''
        else:
            prefix = event_type_prefix.upper() + '_'
        return SB_CUSTOMER_ID + '_' + prefix + event_name + '_' + d

    @staticmethod
    def generate_destination_path(event_name, event_type_prefix=None):
        if event_type_prefix is None:
            prefix = ''
        else:
            prefix = event_type_prefix.capitalize() + '_'
        return 'Responsys_Contact_Event/' + prefix + event_name.capitalize() + '/'

    @staticmethod
    def generate_events(event_names, event_type_prefix):
        events_file_name = list(map(lambda event:
                                    pull_responsys_contact_events.generate_file_name(event, event_type_prefix),
                                    event_names))
        destination_folder_names = list(map(lambda event:
                                            pull_responsys_contact_events.generate_destination_path(event,
                                                                                                    event_type_prefix),
                                            event_names))
        # for x in range(len(events_file_name)):
        #     print events_file_name[x]
        # for x in range(len(destination_folder_names)):
        #     print destination_folder_names[x]
        return zip(events_file_name, destination_folder_names)


    file_names = pull_responsys_contact_events.list_names(export_folder_name)

    # todo add Uninstalled
    pushEventsName = ['SENT', 'FAIL', 'BUTTON_CLICKED', 'OPEN', 'SKIPPED', 'BOUNCE', 'CLICK']
    pushEvent = pull_responsys_contact_events.generate_events(pushEventsName, "push")

    for file_name in file_names:
        for event_name_path, folder_name_path in pushEvent:
            if event_name_path in file_name.encode('utf-8', 'ignore'):
                logger.info("Loading {} - {}".format(event_name_path, folder_name_path))
                destination = pull_responsys_contact_events.download(export_folder_name + '/' + file_name, file_name)
                pull_responsys_contact_events.upload_to_s3(destination, folder_name_path + file_name)

Raw Text