我写了一个函数来更新CSV文件，通过调用多个API来获取所需的信息。
我的问题是，我可以做一个API来上传CSV文件，并调用这个函数到那个CSV文件。我想给予更新的文件作为对客户端的响应。如何才能实现或有其他方法吗？这里是我的主要功能：

async function processCSV(filePath) {
  try {
    const rows = []
    const uniqueReferenceNumbers = new Set()

    fs.createReadStream(filePath)
      .pipe(csv())
      .on('data', (row) => {
        const referenceNumber = row['Reference Number']
        console.log('reading from csv , referenceNumber:', referenceNumber)
        // Check if the reference number is unique before processing
        if (!uniqueReferenceNumbers.has(referenceNumber)) {
          uniqueReferenceNumbers.add(referenceNumber)
          rows.push(row)
        }
      })
      .on('end', async () => {
        if (rows.length === 0) {
          console.log('No unique reference numbers found in the CSV file.')
          return
        }

        // Assume that brand name is the same for all reference numbers in the CSV
        const brandName = rows[0]['Brand']

        // Make the first API call to get brand_uuid
        const brandApiResponse = await makeAPICallWithRetry(
          `https://api/v2/search/brand?q=${brandName}`
        )
        const brandUuid = brandApiResponse.data.data[0].uuid
        console.log('Brand uuid :', brandUuid)

        // Make the second, third, and fourth API calls for each unique reference number
        const updatedRows = [] // Accumulate modified rows in memory
        for (const row of rows) {
          const referenceNumber = row['Reference Number']

          try {
            // Make the second API call using the obtained brand_uuid and reference_number
            const secondApiResponse = await makeAPICallWithRetry(
              `https://api/v2/search/watch?q=${referenceNumber}&brand_uuid=${brandUuid}`
            )

            // Extract watch_uuid from the second API response
            const watchUuid = secondApiResponse.data.data[0].uuid
            console.log('watch uuid:', watchUuid)
            // Make the third API call to get product info
            const thirdApiResponse = await makeAPICallWithRetry(
              `https://api/v2/watch/info?uuid=${watchUuid}`
            )

            // Make the fourth API call to get product specs
            const fourthApiResponse = await makeAPICallWithRetry(
              `https://api/v2/watch/specs?uuid=${watchUuid}`
            )
            // Make the fifth API call to get price history
            const fifthApiResponse = await makeAPICallWithRetry(
              `https://api/v2/watch/price?uuid=${watchUuid}`
            )
            row['Product Info'] = thirdApiResponse
              ? JSON.stringify(thirdApiResponse.data, null, 2)
              : ''
            row['Product Specs'] = fourthApiResponse
              ? JSON.stringify(fourthApiResponse.data, null, 2)
              : ''
            row['Price History'] = fifthApiResponse
              ? JSON.stringify(fifthApiResponse.data, null, 2)
              : console.log(
                  `updating ${referenceNumber} with ${row['Product Info']}, ${row['Product Specs']} and ${row['Price History']} `
                )
            // Add the modified row to the accumulator
            updatedRows.push(row)
          } catch (error) {
            // Handle errors appropriately, e.g., log the error, skip the row, etc.
            console.error(
              `Error processing row for referenceNumber ${referenceNumber}: ${error.message}`
            )
            // Stop the entire process if the maximum number of retries is exceeded
            if (
              error.message.includes('Exceeded the maximum number of retries')
            ) {
              // Write accumulated data to the CSV before rethrowing the error
              if (updatedRows.length > 0) {
                const csvData = Papa.unparse(updatedRows, { header: true })
                fs.writeFileSync(filePath, csvData)
              }
              throw error
            }
          }
        }

        // Update the CSV file with the modified rows
        const csvData = Papa.unparse(rows, { header: true })
        fs.writeFileSync(filePath, csvData)

        // Process is complete, you can do something with the results
        console.log('API calls complete, CSV file updated')
      })
  } catch (error) {
    // Handle errors appropriately
    console.error(`Error processing CSV: ${error.message}`)
  }
}

字符串