使用R语言循环与Quantmod库批量采集股票数据并合并为单一数据框

原有代码存在的问题 #

• 股票代码列表存在重复值DRI，会导致重复拉取和数据合并时列名冲突
• 直接批量调用getSymbols没有错误捕获逻辑，遇到单个标的拉取失败就会影响整体结果，出现漏抓
• 没有针对拉取结果的校验逻辑，无法确认是否所有标的都成功返回数据

优化后循环实现代码 #

library(quantmod)
library(TTR) 

# 去重后的股票代码列表
stocks <- unique(c("MRO", "TSLA", "HAL", "XOM", "DIN", "DRI", "DENN","WEN", "SPCE", "DE", "DRI", "KSS", "AAL","DFS", "LYV","SPXL"))
# 初始化空数据框存储最终收益率数据
pframe1 <- data.frame()
# 初始化向量存储拉取失败的标的
fail_stocks <- c()

# 循环逐个拉取股票数据
for (s in stocks) {
  # 错误捕获，避免单个标的拉取失败中断整个循环
  res <- tryCatch({
    getSymbols(s, from = "2014-02-01", to = "2016-01-01", auto.assign = FALSE)
  }, error = function(e) {
    return(NULL)
  })
  # 校验拉取结果
  if (is.null(res) || nrow(res) == 0) {
    fail_stocks <- c(fail_stocks, s)
    next
  }
  # 提取调整后收盘价计算收益率
  adj_price <- Ad(res)
  yield <- diff(adj_price)*100/head(adj_price, -1)
  # 合并到总数据框，自动按日期对齐
  if (nrow(pframe1) == 0) {
    pframe1 <- as.data.frame(yield)
    colnames(pframe1) <- s
  } else {
    temp_df <- as.data.frame(yield)
    colnames(temp_df) <- s
    pframe1 <- merge(pframe1, temp_df, by = "row.names", all = TRUE)
    rownames(pframe1) <- pframe1$Row.names
    pframe1$Row.names <- NULL
  }
}

# 输出拉取失败的股票代码便于排查
if (length(fail_stocks) > 0) {
  message("以下标的拉取失败：", paste(fail_stocks, collapse = ", "))
}

优化点说明 #

• 先对股票代码列表做unique去重，避免重复拉取和列冲突
• 采用逐标的循环拉取逻辑，搭配tryCatch做错误捕获，单个标的拉取失败不会中断整个流程
• 新增拉取结果校验和失败标的记录逻辑，拉取完成后会输出失败标的列表，方便后续排查漏抓原因
• 合并数据时采用按日期全对齐逻辑，不会因为个别标的日期缺失影响其他标的数据完整性
• 保留原有计算调整后收盘价涨跌幅的逻辑，计算结果和原有逻辑一致

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