def METHOD_NAME(self, ocean_backend, events=False):
    items_to_enrich = []
    num_items = 0
    ins_items = 0
    for item in ocean_backend.fetch():
        analysis_data = item['data']['analysis']
        for file_path in analysis_data:
            for smell in analysis_data[file_path]['smells']:
                eitem = self.get_rich_item(item, file_path, smell)
                items_to_enrich.append(eitem)
        if len(items_to_enrich) < MAX_SIZE_BULK_ENRICHED_ITEMS:
            continue
        num_items += len(items_to_enrich)
        ins_items += self.elastic.bulk_upload(items_to_enrich, self.get_field_unique_id())
        items_to_enrich = []
    if len(items_to_enrich) > 0:
        num_items += len(items_to_enrich)
        ins_items += self.elastic.bulk_upload(items_to_enrich, self.get_field_unique_id())
    if num_items != ins_items:
        missing = num_items - ins_items
        logger.error("[dockersmells] {}/{} missing items".format(
                     missing, num_items))
    else:
        logger.info("[dockersmells] {} items inserted".format(
                    num_items))
    return num_items