文件名称：collectortoqueue:节点的 Kue 处理
文件大小：95KB
文件格式：ZIP
更新时间：2024-06-19 07:44:54
JavaScript
收集器队列 该库为Alpha版本。 我们将努力支持图书馆，但我们保留在必要时进行不兼容更改的权利。 它是一个基于 Kue 的分布式任务管理器。 （节点.js） librarycollectortoqueue的目标是一个用kue(node.js)管理任务的库 它由3部分组成： 收集器：从源（数据库、Mongo、Mysql、Redis、文本文件或数组）收集数据 TaskManager : 用数据做点什么 Saver：将数据保存在某处（Mongo、MySql、Redis 等） 简单示例 我们创建 2 个文件： generate.js ：用于生产任务。 abuse.js：用于计算任务。 Comsume.js 可以部署在大量机器或 VM 中。 任务有过程 ###创建文件producer.js //define the source of data (here mysql) va
【文件预览】：
collectortoqueue-master
----example()
--------collectortoqueueDb.json(163B)
--------collectorMongoExample.ts(2KB)
--------collectorMySqlExample.js.map(1KB)
--------jobSqlExemple.js.map(1KB)
--------jobSqlExemple.ts(1KB)
--------collectorTxtExample.js(675B)
--------collectorMongoExample.js(2KB)
--------collectorMySqlExample.ts(1KB)
--------jobTxtExemple.js.map(920B)
--------collectorArrayExample.js(880B)
--------collectorMySqlExample.js(1KB)
--------collectorTxtExample.ts(880B)
--------jobTxtExemple.js(929B)
--------jobSqlExemple.js(981B)
--------collectorArrayExample.ts(980B)
--------collectorTxtExample.js.map(667B)
--------jobTxtExemple.ts(1KB)
----config()
--------log.js(1KB)
--------sockets.js(7KB)
--------http.js(4KB)
--------globals.js(3KB)
--------locales()
--------i18n.js(3KB)
--------routes.js(2KB)
--------csrf.js(3KB)
--------session.js(4KB)
--------blueprints.js(9KB)
--------policies.js(2KB)
--------connections.js(6KB)
--------views.js(6KB)
--------kue.js(443B)
--------env()
--------cors.js(4KB)
--------bootstrap.js(627B)
--------models.js(2KB)
--------local.js(5KB)
----producer.js(7KB)
----remover.js(5KB)
----job()
--------JobKue.js(7KB)
--------JobMaster.ts(4KB)
--------JobKue.js.map(6KB)
--------JobKue.ts(6KB)
--------JobMaster.js.map(4KB)
--------JobMaster.js(4KB)
----poubelle()
--------producer.js(1015B)
--------consumer.js.map(673B)
--------producer.js.map(1KB)
--------producer.ts(1KB)
--------consumer.js(558B)
--------consumer.ts(522B)
----app.js.map(1KB)
----collector()
--------GetMongoData.ts(3KB)
--------GetMongoData.js(4KB)
--------GetTxtData.ts(2KB)
--------GetTxtData.js(3KB)
--------GetArrayData.js(2KB)
--------GetDataMaster.js.map(2KB)
--------GetArrayData.ts(1KB)
--------GetSqlData.js.map(4KB)
--------GetTxtData.js.map(2KB)
--------GetDataMaster.js(3KB)
--------GetSqlData.ts(4KB)
--------GetSqlData.js(5KB)
--------GetDataMaster.ts(2KB)
----package.json(931B)
----data()
--------toto.txt(51B)
----api()
--------services()
----.npmignore(593B)
----app.ts(1KB)
----ui()
--------ui.js.map(508B)
--------ui.ts(270B)
--------kue-ui.js(822B)
--------kue-ui.js.map(982B)
--------kue-ui.ts(769B)
--------ui.js(366B)
----remover.ts(5KB)
----producer.ts(7KB)
----.gitignore(623B)
----consumer.js(5KB)
----saver()
--------MasterSaver.js(245B)
--------DocumentDbSaver.js.map(8KB)
--------DocumentDbSaver.js(8KB)
--------MongoSaver.js(3KB)
--------MasterSaver.js.map(266B)
--------MongoSaver.ts(2KB)
--------DocumentDbSaver.ts(7KB)
--------MongoSaver.js.map(3KB)
--------MasterSaver.ts(122B)
----app.js(1KB)
----README.md(3KB)
----consumer.ts(5KB)