JSON 服务器 - 使用 cronjob 更新数据库

Posted 2023-03-27

【中文标题】JSON 服务器 - 使用 cronjob 更新数据库

【英文标题】：JSON Server - Using a cronjob to update the database

【发布时间】：2020-01-18 18:25:30

【问题描述】：

我正在尝试使用JSON server 创建一个 API，从而定期以编程方式添加新数据。

目标是每小时从另一个 api 查询数据，并用这些新数据更新数据库。

目前我正在关注文档中的示例，并添加了节点 cron 模块的使用：

// index.js
var cron = require('cron').CronJob;

module.exports = () => 
 const data = 
  categories: []
 ;

 const job = new cron('*/4 * * * * *', function() 
  const d = new Date();
  data.categories.push(d);

  console.log('array updated')
 );

 job.start();

 return data;
;

这不起作用，数组保持为空。

我想知道更新数据库的解决方案是什么样的？

我的服务器代码如下所示：

const jsonServer = require('json-server')
const fs = require('fs');
const jsonfetch = require('./index.js');
const server = jsonServer.create()

fs.writeFileSync('/tmp/db.json', JSON.stringify(jsonfetch()));

const router = jsonServer.router('/tmp/db.json')

const options = 
  static: __dirname + '/public'


const middlewares = jsonServer.defaults(options)
const port = process.env.PORT || 3000

server.use(middlewares)
server.use('/api', router)

server.listen(port, () => 
  console.log('JSON Server is running on ' + port)
)

【参考方案1】：

我以前使用 npm node-cron 库做过类似的事情。这是一个基本示例，但我也编写了一个 es6 类，因此如果您愿意，我可以为您提供更复杂的内容。

import axios from 'axios'

let node_cron = require('node-cron');

node_cron.schedule('* * * * *', async function () 
   // Do your thing here.

【讨论】：

感谢@banderson，但它似乎没有工作。我认为这是因为在 index.js 中执行 cron 作业之前返回数据，但在 cron 作业中返回数据破坏代码。让 node_cron = require('node-cron'); module.exports = () => const data = categories: [ ] ; node_cron.schedule('*/3 * * * * *', async function () data.categories.push('test'); console.log('pushed') );返回数据； ;

@ogot 我能够在每个 cron 间隔进行控制台日志。问题可能是返回语句。为什么需要返回更新数据库？你可以做一个异步等待然后插入到数据库中。将 .catch 链接到 await 和控制台记录发生的任何错误。

node_cron.schedule('* * * * *', async function () console.log('Checking connectivity.'); await axios.post($endpoint, user_email: "[e-mail]" , ) .catch((err, res) => console.log('error: ', err); console.log('res: ', res.body); ); );

【参考方案2】：

在nestJS 中，您可以使用@nestjs/schedule 和@types/cron 包来安排API 请求。

 1. npm install --save @nestjs/schedule
 2. npm install --save-dev @types/cron

接下来将调度模块添加到 app.module.ts 文件中，如下所示。

@Module(
    imports: [
      ScheduleModule.forRoot()
    ]
  )

然后用下面的装饰器添加实现功能。

 @Cron('60 * * * * *')
  public async getAllImges(): Promise<ImagesDto[]>