如何在rowwise mutate中添加延迟以控制API请求频率

在逐行调用API时，为了避开请求频率限制，你可以把API调用和延迟操作结合起来，两种实现方式如下：

方法1：直接在mutate中嵌入延迟逻辑 #

用{}包裹多行表达式，先执行API调用、保存结果，再添加延迟，最后返回结果：

library(tidyverse)

data %>% 
    rowwise() %>%
    mutate(authors = {
        # 调用API并保存结果
        api_result <- list(get_API_value(arg1 = val1, arg2 = val2))
        # 等待1秒
        Sys.sleep(1)
        # 返回结果给authors列
        api_result
    })

方法2：封装成自定义函数（更整洁） #

把带延迟的API调用逻辑封装成独立函数，让代码结构更清晰：

library(tidyverse)

# 定义带延迟的API调用函数
call_api_with_delay <- function(arg1, arg2) {
    api_result <- get_API_value(arg1 = arg1, arg2 = arg2)
    Sys.sleep(1)
    list(api_result)
}

# 调用函数处理每行数据
data %>% 
    rowwise() %>%
    mutate(authors = call_api_with_delay(arg1 = val1, arg2 = val2))

额外建议 #

如果API的限流规则不是严格的每秒1次，也可以用随机延迟替代固定延迟，比如Sys.sleep(runif(1, 0.5, 1.5))，这样能模拟更自然的请求节奏，进一步降低被限流的概率。

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