如何使用R调用Amplitude Export API实现数据导出？

你给出的curl命令本质是带基础身份认证的GET请求，直接将返回的二进制流写入本地zip文件，R中可以通过两种常用方案实现： #

方案1：使用httr包实现（推荐，语法更简洁） #

httr是R最常用的HTTP请求封装包，对应实现代码如下：

# 首次使用先安装包
install.packages("httr")
library(httr)

# 替换为你的实际配置参数
api_key <- "你的Amplitude API_Key"
secret_key <- "你的Amplitude Secret_Key"
start_time <- "20150201T5" # 时间格式为YYYYMMDDTHH，时区为UTC
end_time <- "20150203T20"
output_zip_path <- "yourfilename.zip"

# 发送请求并直接写入本地文件，避免大文件占用内存
response <- GET(
  url = "https://amplitude.com/api/2/export",
  query = list(start = start_time, end = end_time),
  authenticate(user = api_key, password = secret_key),
  write_disk(path = output_zip_path, overwrite = TRUE)
)

# 校验请求结果
if (http_type(response) == "application/zip") {
  message("导出成功，文件已保存至：", output_zip_path)
} else {
  message("请求异常，错误码：", status_code(response), "，返回信息：", content(response, "text"))
}

方案2：使用curl包实现（更贴近原生curl逻辑） #

如果习惯用原生curl相关功能，可以用curl包实现：

# 首次使用先安装包
install.packages("curl")
library(curl)

# 替换为你的实际配置参数
api_key <- "你的Amplitude API_Key"
secret_key <- "你的Amplitude Secret_Key"
start_time <- "20150201T5"
end_time <- "20150203T20"
output_zip_path <- "yourfilename.zip"

# 构造请求地址
request_url <- sprintf("https://amplitude.com/api/2/export?start=%s&end=%s", start_time, end_time)

# 配置基础认证参数
curl_handle <- new_handle(
  httpauth = 1, # 指定为HTTP基础认证模式
  userpwd = paste0(api_key, ":", secret_key)
)

# 直接下载文件到本地
curl_download(url = request_url, destfile = output_zip_path, handle = curl_handle)

注意事项 #

• 导出的zip包解压后为逐行存储的JSON格式事件数据，大文件可以用jsonlite::stream_in()函数流式读取，避免内存溢出
• 如果导出时间范围超过1个月，建议按天拆分请求，避免单次请求超时
• 时间参数的时区为UTC，不要传入本地时区时间，否则会出现数据范围偏差

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