+ +
+

pyams_content_es package

+ +
+

Submodules

+
+
+

pyams_content_es.document module

+
+
+class pyams_content_es.document.ElasticMixin
+

Bases: pyramid_es.mixin.ElasticMixin

+

ElasticSearch base mixin class

+
+
+elastic_document()
+
+ +
+
+elastic_mapping()
+
+ +
+
+id
+
+ +
+
+internal_id
+
+ +
+ +
+
+pyams_content_es.document.WfSharedContentIndexInfo(content)
+
+ +
+
+

pyams_content_es.include module

+
+
+pyams_content_es.include.handle_new_application(event)
+

Start indexer process when application created

+
+ +
+
+pyams_content_es.include.include_package(config)
+

Pyramid include

+
+ +
+
+

pyams_content_es.index module

+
+
+pyams_content_es.index.handle_added_document(event)
+

Handle added document

+
+ +
+
+pyams_content_es.index.handle_modified_document(event)
+

Handle modified document

+
+ +
+
+pyams_content_es.index.handle_removed_document(event)
+

Handle removed document

+
+ +
+
+pyams_content_es.index.index_document(status, document)
+
+ +
+
+pyams_content_es.index.unindex_document(status, document)
+
+ +
+
+

pyams_content_es.process module

+
+
+class pyams_content_es.process.BaseIndexerProcess(settings, group=None, target=None, name=None, *args, **kwargs)
+

Bases: multiprocessing.context.Process

+

Base indexer process

+
+
+run()
+
+ +
+
+update_index(client, document)
+

Update index

+
+ +
+ +
+
+class pyams_content_es.process.ContentIndexerHandler
+

Bases: object

+

Content indexer handler

+
+
+index(settings)
+
+ +
+
+test(settings)
+
+ +
+
+unindex(settings)
+
+ +
+ +
+
+class pyams_content_es.process.ContentIndexerMessageHandler(process, stream, stop, handler=None, json_load=-1)
+

Bases: pyams_zmq.handler.ZMQMessageHandler

+

Content indexer message handler

+
+
+handler
+

alias of ContentIndexerHandler

+
+ +
+ +
+
+class pyams_content_es.process.ContentIndexerProcess(zmq_address, handler, registry)
+

Bases: pyams_zmq.process.ZMQProcess

+

Content indexer ZMQ process

+
+ +
+
+class pyams_content_es.process.IndexerProcess(settings, group=None, target=None, name=None, *args, **kwargs)
+

Bases: pyams_content_es.process.BaseIndexerProcess

+

Content indexer process

+
+
+update_index(client, document)
+
+ +
+ +
+
+class pyams_content_es.process.IndexerThread(process)
+

Bases: threading.Thread

+

Content indexer thread

+
+
+run()
+
+ +
+ +
+
+class pyams_content_es.process.UnindexerProcess(settings, group=None, target=None, name=None, *args, **kwargs)
+

Bases: pyams_content_es.process.BaseIndexerProcess

+

Content un-indexer process

+
+
+update_index(client, document)
+
+ +
+ +
+
+

pyams_content_es.site module

+
+
+class pyams_content_es.site.ContentIndexerGenerationsChecker
+

Bases: object

+

Content indexer utility generations checker

+
+
+evolve(site, current=None)
+

Check for required utilities

+
+ +
+
+generation = 1
+
+ +
+ +
+
+pyams_content_es.site.handle_new_local_site(event)
+

Create a new indexer utility when a site is created

+
+ +
+
+pyams_content_es.site.site_index(request)
+

Index all site contents in ElasticSearch

+
+ +
+
+

pyams_content_es.utility module

+
+
+class pyams_content_es.utility.ContentIndexerUtility
+

Bases: persistent.Persistent, zope.container.contained.Contained

+

Content indexer utility

+
+
+index_document(document)
+

Send index request for given document

+
+ +
+
+test_process()
+

Send test request to indexer process

+
+ +
+
+unindex_document(document)
+

Send unindex request for given document

+
+ +
+
+zodb_name
+

Computed attributes based on schema fields

+

Field properties provide default values, data validation and error messages +based on data found in field meta-data.

+

Note that FieldProperties cannot be used with slots. They can only +be used for attributes stored in instance dictionaries.

+
+ +
+ +
+
+

Module contents

+
+
+pyams_content_es.includeme(config)
+

Pyramid include

+
+ +
+
+ + +