'Implements sqs query that includes an analyzer'

def process_query_sqs_analyzer(self, key, val, action):

    (query, analyzer) = val
    return {'simple_query_string': {'fields': [key], 'query': query, 'analyzer': analyzer, 'default_operator': 'or'}}
