Dynamic ElasticSearch mappings

elasticsearch_mapping.py

MAPPING = {
    '_default_': {
        '_all': {'enabled': False},
        'dynamic_templates': [
            {
                'analyzed_body': {
                    'match': 'body',
                    'match_mapping_type': 'string',
                    'mapping': {
                        'type': 'string',
                        'index': 'analyzed',
                    }
                }
            },
            {
                'default_not_analyzed': {
                    'match': '*',
                    'match_mapping_type': 'string',
                    'mapping': {
                        'type': 'string',
                        'index': 'not_analyzed',
                    }
                }
            },
        ]
    }
}

_seen_indices = set()


def ensure_index(es_conn, index_format, now):
    index = now.strftime(index_format)
    if index in _seen_indices:
        return index
    _seen_indices.add(index)
    es_conn.indices.create_index_if_missing(index, settings={'mappings': MAPPING})
    return index