@@ -0,0 +1,892 @@
+import logging%0A%0Afrom elasticsearch import Elasticsearch%0A%0Afrom scrapi import settings%0Afrom scrapi.processing.base import BaseProcessor%0A%0Aes = Elasticsearch(%0A    settings.ELASTIC_URI,%0A    request_timeout=settings.ELASTIC_TIMEOUT%0A)%0A%0Alogging.getLogger('elasticsearch').setLevel(logging.WARN)%0Alogging.getLogger('elasticsearch.trace').setLevel(logging.WARN)%0Alogging.getLogger('urllib3').setLevel(logging.WARN)%0Alogging.getLogger('requests').setLevel(logging.WARN)%0Aes.cluster.health(wait_for_status='yellow')%0A%0A%0Aclass ElasticsearchProcessor(BaseProcessor):%0A    NAME = 'elasticsearch'%0A%0A    def process_raw(*args, **kwargs):%0A        pass%0A%0A    def process_normalized(self, raw_doc, normalized):%0A        es.index(%0A            body=normalized.attributes,%0A            refresh=True,%0A            index='share',%0A            doc_type=normalized%5B'source'%5D,%0A            id=normalized%5B'id'%5D%5B'serviceID'%5D,%0A        )%0A

add elasticsearch processor for scrapi