當我日誌pyfunc mlflow模型,它生成一個頁麵,這對於使用模型在生產有用的代碼。
在火花DataFrame作出預測預測:從pyspark.sql進口mlflow。功能導入結構、坳logged_model = '運行:/ 1 d…/ del121’#負荷模型作為引發UDF。覆蓋result_type如果模型不返回值的兩倍。loaded_model = mlflow.pyfunc。spark_udf(火花,model_uri = logged_model result_type =“雙”)#火花DataFrame預測。df。withColumn(“預測”,loaded_model (struct(*地圖(col df.columns))))預測熊貓DataFrame:進口mlflow logged_model = '運行:/ 1 d…/ del121’# PyFuncModel負載模型。loaded_model = mlflow.pyfunc.load_model (logged_model) #熊貓DataFrame預測。熊貓作為pd loaded_model.predict導入(pd.DataFrame(數據)
有可能改變這一/定製嗎?理想我想包括一些參數自模型用於特定的數據(數據從X表但過濾某些網站)
