6

在设计了一个基于Tidymodels配方的工作流，它经过调整然后适合一些训练数据，我不清楚哪些对象（适合的“工作流程”、“食谱”、..etc）应该保存到磁盘以用于预测新的生产中的数据。我知道我可以使用saveRDS()/ readRDS()、write_rds()/read_rds()或其他选项来实际保存/加载这些对象，但是哪些？

在一个干净的 R 环境中，我将收到新的原始数据，这些数据需要使用我在训练模型时使用的“配方”进行预处理。然后，我想在预处理后根据该数据进行预测。如果我打算像处理训练数据一样使用prep()和bake()函数来预处理新数据，那么我将最少需要它似乎开始prep()工作的配方和原始训练数据。另外，我还需要拟合模型/工作流程来进行预测。所以看起来是三个对象。pull_workflow_prepped_recipe()如果我将 SESSION 1 中的工作流对象保存到磁盘，那么我可以在 SESSION 2 中分别使用和从中提取配方和模型pull_workflow_fit()。但prep()似乎需要原始训练数据，我可以通过早期使用将其保留在工作流程中retain = TRUE...但是在调用fit(). 听我的呼救声！:)

所以，想象一下两个不同的 R 会话，第一个会话我进行所有的训练和模型构建，第二个会话是一些正在运行的生产应用程序，它使用从第一个会话中学到的东西。我在 SESSION1 底部的箭头处以及 SESSION 2 中的多个位置需要帮助。我使用 Tidymodels Get Started作为此示例的基础。

第一节

library(tidymodels)
library(nycflights13)
library(readr)
set.seed(123)
flight_data <- 
  head(flights, 500) %>% 
  mutate(
    arr_delay = ifelse(arr_delay >= 30, "late", "on_time"),
    arr_delay = factor(arr_delay),
    date = as.Date(time_hour)
  ) %>% 
  inner_join(weather, by = c("origin", "time_hour")) %>% 
  select(dep_time, flight, origin, dest, air_time, distance, carrier, date, arr_delay, time_hour) %>% 
  na.omit() %>% 
  mutate_if(is.character, as.factor)

set.seed(555)
data_split <- initial_split(flight_data, prop = 3/4)
train_data <- training(data_split)
test_data  <- testing(data_split)

flights_rec <- 
  recipe(arr_delay ~ ., data = train_data) %>% 
  update_role(flight, time_hour, new_role = "ID") %>% 
  step_date(date, features = c("dow", "month")) %>%
  step_holiday(date, holidays = timeDate::listHolidays("US")) %>%
  step_rm(date) %>%
  step_dummy(all_nominal(), -all_outcomes()) %>%
  step_zv(all_predictors())

lr_mod <- 
  logistic_reg() %>% 
  set_engine("glm")

flights_wflow <- 
  workflow() %>% 
  add_model(lr_mod) %>% 
  add_recipe(flights_rec)

flights_fit <- 
  flights_wflow %>% 
  fit(data = train_data)

predict(flights_fit, test_data)

### SAVE ONE OR MORE OBJECTS HERE FOR NEXT SESSION  <------------
# What to save? workflow (pre or post fit()?), recipe, training data...etc.
write_rds(flights_wflow, "flights_wflow.rds")  # Not fitted workflow
write_rds(flights_fit, "flights_fit.rds")  # Fitted workflow

会议 2

### READ ONE OR MORE OBJECTS HERE FROM PRIOR SESSION <------------
flights_wflow <- read_rds("flights_wflow.rds")
flights_fit <- read_rds("flights_fit.rds")

# Acquire new data, do some basic transforms as before
new_flight_data <- 
  tail(flights, 500) %>% 
  mutate(
    arr_delay = ifelse(arr_delay >= 30, "late", "on_time"),
    arr_delay = factor(arr_delay),
    date = as.Date(time_hour)
  ) %>% 
  inner_join(weather, by = c("origin", "time_hour")) %>% 
  select(dep_time, flight, origin, dest, air_time, distance, carrier, date, arr_delay, time_hour) %>% 
  na.omit() %>% 
  mutate_if(is.character, as.factor)

# Something here to preprocess the data with recipe as in SESSION 1 <----------
# new_flight_data_prep <- prep(??)
# new_flight_data_preprocessed <- bake(??)

# Predict new data
predict(flights_fit, new_data = new_flight_data_preprocessed)
4

2 回答 2

7

根据您的限制，您可以灵活地处理此问题，但通常我会建议保存/序列化拟合的工作流程，也许在使用屠夫减小其大小之后。您可以在这个 repo 中看到一个示例模型拟合脚本，该脚本最后显示了我如何保存拟合的工作流程。

当您使用此工作流程进行预测时，需要记住一些事项。我在同一个 repo 中有一个示例 Plumber API，它演示了预测该特定工作流所需的内容。请注意，预测所需的包是如何为此 API 加载/附加的包。我没有使用所有的 tidymodel，而是只使用了我需要的特定包，以获得更好的性能和更小的容器。

于 2021-02-04T23:30:49.883 回答
0

保存拟合的工作流程对我不起作用。当尝试使用新数据进行预测时，要求目标变量（流失模型）

predict(churn_model, the_data)
Error: Problem with `mutate()` column `churn`.
i `churn = dplyr::if_else(churn == 1, "yes", "no")`.
x object 'churn' not found

我仍然不明白为什么要求数据中不应该出现的列，因为它是我试图预测的变量......

于 2021-06-09T11:38:49.510 回答