R语言模拟定时逐行接收数据并处理中间结果的实现问题

核心逻辑是遍历源数据框的每一行，逐行追加到目标数据框后立即执行自定义处理逻辑，再通过睡眠函数控制间隔，完整可运行代码如下：

# 1. 初始化源数据
my_data <- data.frame(id = 1:10,
                      person = sample(LETTERS[1:3], 10, replace = TRUE),
                      score = sample(50:100, 10, replace = TRUE))

# 2. 初始化空的目标数据框和存储中间结果的向量
my_data2 <- data.frame()
mean_history <- c()

# 3. 逐行流入处理循环，间隔15秒
for (i in 1:nrow(my_data)) {
  # 追加当前行到目标数据框
  my_data2 <- rbind(my_data2, my_data[i, ])
  # ------------- 自定义每轮处理逻辑开始 -------------
  # 打印当前的my_data2
  print("当前my_data2内容：")
  print(my_data2)
  # 计算当前score均值
  current_mean <- mean(my_data2$score)
  print(paste0("当前score均值：", round(current_mean, 2)))
  # 存储均值到历史结果
  mean_history <- c(mean_history, current_mean)
  # ------------- 自定义每轮处理逻辑结束 -------------
  # 非最后一轮执行睡眠等待
  if (i < nrow(my_data)) {
    Sys.sleep(15)
  }
}

# 运行结束后可以查看所有历史均值
print("所有轮次的均值结果：")
print(mean_history)

使用说明 #

• 如果需要调整间隔时长，修改Sys.sleep()的参数即可，单位为秒
• 两个注释线中间的处理逻辑可以按需替换，比如新增指标计算、绘图、数据导出等操作，所有中间状态的my_data2和计算结果都可以直接在循环内调用
• 若需要将每轮的中间结果持久化存储，可以在处理逻辑中加入write.csv()等导出语句，每次迭代直接写入文件即可

内容的提问来源于stack exchange，提问作者mmw