0

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

我已经添加了我看到的必要模块，但我无法通过 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 文件中的信息并将其保存在 CSV 文件中src / output？

4

1 回答 1

0

您可以使用 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();
于 2021-06-05T18:43:03.110 回答