使用 R 的 Plumber - 创建 GET 端点来托管 CSV 格式的数据而不是 JSON

我认为这是 R 管道工库的一个很好的快速演示，但主要是我正在努力以 csv 格式提供数据

我正在使用 R 的管道工包来托管我的一些体育数据的 API 端点。目前，我有一些数据可以获取我正在尝试提供的 MLB 棒球队的获胜总数。使用水管工，我设置了以下两个脚本：

设置API.R：使用两个 GET 端点设置我的 API：

library(plumber)
library(jsonlite)

# load in some test sports data to host
mydata = structure(list(Team = structure(c(8L, 20L, 7L, 28L, 2L, 30L, 
23L, 1L, 6L, 19L), .Label = c("Angels", "Astros", "Athletics", 
"Blue Jays", "Braves", "Brewers", "Cardinals", "Cubs", "Diamondbacks", 
"Dodgers", "Giants", "Indians", "Mariners", "Marlins", "Mets", 
"Nationals", "Orioles", "Padres", "Phillies", "Pirates", "Rangers", 
"Rays", "Red Sox", "Reds", "Rockies", "Royals", "Tigers", "Twins", 
"White Sox", "Yankees"), class = "factor"), GamesPlayed = c(162L, 
162L, 162L, 162L, 162L, 162L, 162L, 162L, 162L, 162L), CurrentWins = c(92L, 
75L, 83L, 85L, 101L, 91L, 93L, 80L, 86L, 66L)), .Names = c("Team", 
"GamesPlayed", "CurrentWins"), row.names = c(NA, 10L), class = "data.frame")

# create a GET request for shareprices (in JSON format)
#* @get /shareprices_json
getSPs <- function(){ 
  return(toJSON(mydata))
}

# create a GET request for MLB shareprices (in CSV format)
#* @get /shareprices_csv
csvSPs <- function(){
  return(mydata)
}

# run both functions (i think needed for the endpoints to work)   
getSPs()
csvSPs()

RunAPI.R：plumb的setupAPI.R，获取本地托管的端点

library(plumber)
r <- plumb("setupAPI.R") 
r$run(port=8000)

. . .

在控制台中运行 RunAPI.R 代码后，当我转到端点时，我的http://127.0.0.1:8000/shareprices_csv http://127.0.0.1:8000/shareprices_csv端点显然返回一个 JSON 对象，而我的http://127.0.0.1:8000/shareprices_json http://127.0.0.1:8000/shareprices_json端点似乎奇怪地返回长度为 1 的 JSON，字符串中的 JSON 作为返回 JSON 中的唯一元素。

简而言之，我现在可以看到，我应该简单地返回数据帧，而不是返回 JSON（数据帧），以获得端点主机 JSON 格式的数据，however我仍然不知道如何以 CSV 格式提供这些数据。这在水管工中可能吗？ setupAPI.R 函数中的 return 语句应该是什么样子？任何帮助表示赞赏！

如果对任何人有帮助，只需发布​​此答案即可！

Jeff 的响应效果非常好，但当您必须返回一个大的 CSV 文件时，响应会变得非常慢。我在处理 22 MB 文件时遇到了问题。

如果您之前将 CSV 写入磁盘，则更快的解决方案是使用include_file函数（文档here https://www.rdocumentation.org/packages/plumber/versions/0.4.4/topics/include_file):

举个例子：

#* @get /iris_csv
getIrisCsv <- function(req, res) {
    filename <- file.path(tempdir(), "iris.csv")
    write.csv(iris, filename, row.names = FALSE)
    include_file(filename, res, "text/csv")
}

因此，这取决于您的用例：

• 如果您返回一个小 csv 并且不想将其写入磁盘：使用 Jeff 的解决方案
• 如果您的 CSV 是中型或大型 (> 2MB) 或者您已将其存储在磁盘上：使用include_file解决方案

希望能帮助到你！