How can I retrieve data from the request body sent to a Plumber API?

[akramh]

I am currently working on a project involving a Plumber API, and I've encountered a challenge related to handling CSV files in the body of HTTP requests.

I have a Plumber API where I need to receive 2 CSV files in the body of a POST request sent from Postman (for example). I am unsure how to do that ?

I've read about Plumber Parsers and there was a parser_csv but couldn't figure out how to use that to get that data from request body !!

    #* Process two files in the request body
    #* @post /process_files
    #* @parser multipart/form-data
    function(req, res) {

      if (is.null(req$files) || length(req$files) < 2) {
        res$status <- 400
        res$body <- '{"error": "Two files must be included in the request."}'
        return()
      }
    
      file1 <- req$files$file1
      file2 <- req$files$file2

  ## here I  process the data 

  res$status <- 200
  res$body <- '{"message": "Files processed successfully."}'
}

Can someone please guide me?

[meztez]

The answer below could probably help you understand plumber parsers?

Plumber request body receive and read CSV, XLSX, and RDS files.

Plumber has an input parser system based on the mime type in the request body. By default, only a handful of parsers are activated (txt, json, query, body, octet). In the solution below, I added two parsers, one for each match mime type (xls and xlsx). I also activated all parsers with the annotation #* @parser all. If plumber cannot find a matching activated parser for a mime type, it returns a raw vector named with the filename. library(plumber) parser_xlsx <- function(...) { parser_read_file(function(tmpfile) { readxl::read_xlsx(tmpfile, sheet = 1) }) } parser_xls <- function(...) { parser_read_file(function(tmpfile) { readxl::read_xls(tmpfile, sheet= 1) }) } register_parser(…

A solution similar to this?

#* Process two files in the request body
#* @post /process_files
#* @param files:[file]
#* @parser multi
#* @parser csv
function(files, req, res) {

      if (length(files) < 2) {
        res$status <- 400
        res$body <- '{"error": "Two files must be included in the request."}'
        return()
      }
    
      file1 <- files[[1]]
      file2 <- files[[2]]

  ## here I  process the data 

  res$status <- 200
  res$body <- '{"message": "Files processed successfully."}'
}