0

在生产中服务关联规则的最佳实践是什么？

我使用 FPGrowth 算法的 pyspark 实现来开发关联规则。我想使用这些转换方法根据购物车中的商品向网站用户展示免费产品。

我最初的想法是设置一个调用转换方法的预测 api，但是代码块可能需要很长时间才能运行。

import pyspark
from pyspark.sql import SparkSession
from pyspark.ml.fpm import FPGrowthModel

from flask import jsonify, request, Flask

app = Flask(__name__)


@app.route('/assoications/<item_id>', methods=['GET'])
def predict(item_id):
    
    items = str(item_id)
   
    spark = SparkSession.builder.appName('rules').getOrCreate()
    model = FPGrowthModel.load('models/1')
    items = spark.createDataFrame([(items, )], ["product_id"])
    response = model.transform(items).take(1)
    #response = items
    return jsonify(response[0][1])
    
if __name__ == '__main__':
    app.run()

转换方法不是用于实时服务吗？在生产中服务我的关联规则的最佳方式是什么？

4

0 回答 0