在 Node JS 中将外部 JSON 转换为 CSV

Question

我正在使用 Node JS 和 Typescript 创建一个项目，我想在其中下载一个 CSV，其中包含 API 包含的 JSON 格式的信息。给定 url http://localhost:3000/?api=api1，我必须阅读与 api1 相关的 JSON。

我已经添加了我看到的必要模块，但我无法通过 url 从外部 JSON 下载 CSV。

这是我的controller：

import { Request, Response } from 'express';
const converter = require("json-2-csv");
const fetch = require("node-fetch");
const fs = require("fs");
const flatten = require('flat');
    
const conf = require(`../config/${process.env.NODE_ENV}.json`);
    
class IndexController {
    public async index(req: Request, res: Response) {
        const api =req.query.api; //api1
        const url = conf.API_MOCS[`${api}`].url; //https://mocks.free.beeceptor.com/api1 

        const env = process.env.NODE_ENV;
        const nameFile = `${env}.${api}.csv`;

        let json = await axios.get(url);

        const header={
          'index':'Index',
          'integer':'Integer',
          'float': 'Float',
          'name': 'Name'};

        let json2csvCallback = function (err:any, csv:any) {
           if (err) throw err;
           const maxRecords = 50;
           const headers = csv.split('\n').slice(0,1);
           const records = csv.split('\n').slice(0,);
           for(let i=1; i<records.length; i=i+maxRecords) {
                let dataOut = headers.concat(records.slice(i, i+maxRecords)).join('\n');
                let id = Math.floor(i/maxRecords)+1;
                 fs.writeFileSync(`${dir}/${nameFile}.${id}.csv`, dataOut);
            }
        };

        converter.json2csv(json.data.items, json2csvCallback);
    }
}
export const indexController = new IndexController(); 

在一个文件中，我以 JSON 格式存储了信息的 URL，我使用变量 (url) 读取了该 URL，如何从该 URL 下载最多 999 行的 CSV 文件中的信息和保存在src / output？

Answer 1

您可以使用 axios 或请求调用该 url，在获得 JSON 响应后，您可以使用 https://www.npmjs.com/package/json2csv 将 JSON 转换为 csv。

import { Request, Response } from 'express';
const converter = require("json-2-csv");
const fetch = require("node-fetch");
const axios = require('axios');
const fs = require("fs");
const flatten = require('flat');
    
const conf = require(`../config/${process.env.NODE_ENV}.json`);
    
class IndexController {
    public async index(req: Request, res: Response) {
        const api =req.query.api; //api1
        const url = conf.API_MOCS[`${api}`].url; //https://mocks.free.beeceptor.com/api1 
        console.log("Getting JSON ...");
        let json = await axios.get("https://mocks.free.beeceptor.com/api1");
        console.log("JSON Fetched ...");
        const header={
        'index':'Index',
        'index_start_at':'Index start',
         'integer':'Integer',
        'float': 'Float',
        'name': 'Name'};
        converter.json2csv([header,...json.data.items], (err:any, csv:any) => {
            if (err) {
                 throw err;
            }
            console.log("Making CSV ...");
            fs.writeFileSync("file.csv",csv);
            console.log("CSV File Is Ready...");

         });    
    }
}
export const indexController = new IndexController();