def METHOD_NAME(self, ocean_backend):
    max_items = self.elastic.max_items_bulk
    current = 0
    total = 0
    bulk_json = ""
    url = self.elastic.get_bulk_url()
    logger.debug("[mozillaclub] Adding items to {} (in {} packs)".format(anonymize_url(url), max_items))
    items = ocean_backend.fetch()
    for item in items:
        if current >= max_items:
            total += self.elastic.safe_put_bulk(url, bulk_json)
            bulk_json = ""
            current = 0
        rich_item = self.get_rich_item(item)
        data_json = json.dumps(rich_item)
        bulk_json += '{"index" : {"_id" : "%s" } }\n' % \
            (item[self.get_field_unique_id()])
        bulk_json += data_json + "\n"  # Bulk document
        current += 1
    if current > 0:
        total += self.elastic.safe_put_bulk(url, bulk_json)
    return total