code: def write(self, items):
          
          if self._read_only:
              raise IOError("Cannot write, Connector created as Read Only")
  
          # Uploading info to the new ES
          docs = []
          for item in items:
              doc = {
                  "_index": self._es_index,
                  "_type": "item",
                  "_id": item["_id"],
                  "_source": item["_source"]
              }
              docs.append(doc)
          # TODO exception and error handling
          helpers.bulk(self._es_conn, docs)
          logger.info(self.__log_prefix + " Written: " + str(len(docs)))
docs: Upload items to ElasticSearch.
  
          :param items: items to be uploaded.