云端大数据实时搜索特价活动

from elasticsearch import Elasticsearch

# 创建Elasticsearch客户端
es = Elasticsearch([{'host': 'localhost', 'port': 9200}])

# 定义索引和文档类型
index_name = "special_offers"
doc_type = "offer"

# 添加特价活动文档
def add_offer(offer_id, product_name, discount):
    doc = {
        'offer_id': offer_id,
        'product_name': product_name,
        'discount': discount
    }
    res = es.index(index=index_name, doc_type=doc_type, id=offer_id, body=doc)
    return res['result']

# 实时搜索特价活动
def search_offers(keyword):
    query = {
        'query': {
            'match': {
                'product_name': keyword
            }
        }
    }
    res = es.search(index=index_name, body=query)
    return res['hits']['hits']

# 示例调用
add_offer(1, "Laptop", 20)
offers = search_offers("Laptop")
for offer in offers:
    print(f"Product: {offer['_source']['product_name']}, Discount: {offer['_source']['discount']}%")