- android - 多次调用 OnPrimaryClipChangedListener
- android - 无法更新 RecyclerView 中的 TextView 字段
- android.database.CursorIndexOutOfBoundsException : Index 0 requested, 光标大小为 0
- android - 使用 AppCompat 时,我们是否需要明确指定其 UI 组件(Spinner、EditText)颜色
应用每 15 分钟运行一个进程,创建许多具有以下格式的输出文件:
<timestamp>-<piece-code>.txt
该进程创建的所有文件都将共享“时间戳”组件,但“片段代码”会有所不同,这意味着我有一个时间戳与许多时间戳的关系我想将其保存在 mongodb 中:
"Registry" { time: (numeric) }
"Piece" { file: (string), piece: (string), registry: (reference) }
在此过程中,我想在创建时间戳之前查找它是否已存在以避免重复,但我的代码似乎无法做到这一点。
预先感谢您的帮助!
const mongoose = require('mongoose');
const Registry = require('../model/Registry');
const Piece = require('../model/Piece');
mongoose.Promise = require('bluebird');
// Set up default mongoose connection
let mongoDB = 'mongodb://127.0.0.1/numbers';
mongoose.connect(mongoDB, {
useMongoClient: true
});
//Get the default connection
let db = mongoose.connection;
// Bind connection to error event
db.on('error', console.error.bind(console, 'MongoDB connection error:'));
// Error handler
let error = (err) => {
console.log("** Error: ", err);
db.close();
};
// Finish routine
let finish = () => {
console.log("I have finished");
db.close();
};
// Create a number if it does not exist already
let newRegistry = (timestamp) => {
return new Promise((resolve, reject) => {
Registry.count({}).then((c) => { console.log(c) })
// Does this Registry exist?
Registry.findOne({ time: timestamp })
.then((reg, err) => {
if (err) {
reject(err);
}
// Create when it does not exist
if (!reg) {
Registry.create({
time: timestamp
}).then((doc, err) => {
if (err) {
reject(err);
}
resolve(doc._id);
})
.catch(error);
} else {
// Else, resolve
resolve(reg._id);
}
});
});
}
let newPiece = (registryId, filename, piece) => {
return Piece.create({
registry: mongoose.Types.ObjectId(registryId),
file: filename,
piece: piece
});
};
let createRegs = (files) => {
return new Promise((resolve, reject) => {
let promises = [];
let total = files.length;
for (let i=0; i<total; i++) {
let fileAr = files[i].split("-");
let time = fileAr[0];
let piece = fileAr[1];
let promise = newRegistry(time)
.then((regId) => {
return newPiece(regId, files[i], piece);
});
promises.push(promise);
}
Promise.all(promises)
.then(() => {
resolve();
})
.catch(error);
});
}
// Register input time and file pieces: one "time" can have many "pieces"
let filenames = ["1512473256-e.txt", "1512471758-a.txt", "1512471892-a.txt", "1512471758-b.txt"];
// Must end up with 3 "Registry" and 4 "Piece" documents
createRegs(filenames)
.then(finish)
.catch(error);
最佳答案
也许值得摆脱数组中的重复数字?通过这样做:
let filtered = [];
numbers.forEach((num) => {
// in case we don't have such entity creating it
if (!filtered.includes(num)) {
filtered.push(num);
}
// in case we have just returning resolved promise
return Promise.resolve();
});
然后在数据库中创建您的实体:
const promises = filtered.map(n => {
Number.findOne({ number: n })
.then(result => if(!result) {
return Number.create({ number: n });
}).catch(err => console.log(err));
});
Promise.all(promise).then(() => /* Doing what you want to do after saving */)
关于node.js - 在链式 Promisified 函数内创建 MongoDB 文档,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/47649326/
一晃五年没写博客了,依旧再C#上耕耘,依旧没有啥建树,现在也不知道.net上还有多少人再使用,在这里分享一些自己觉得写的还算优雅的代码。 对于自己写着完的代码,我特别喜欢链式(来源于jQuer
我正在构建一个吉他和弦查找应用程序。我使用多维数组来表示指板。数组中的每个元素都由具有字符串属性“Note”的 FretSpace 结构表示。为了初始化指板上的音符属性,我传递了要处理的吉他弦的详细信
我在演示代码中使用 setTimeout 函数模拟了 3 个 ajax 调用。我将从一段运行良好的代码开始:所有调用都是并行进行的,我希望所有调用都能成功,否则会出现错误。 var p1 = func
谁能解释一下? a = [2,3,4] b = [5,6,8,9] print(len(a) > 0) print(len(b) > 0) print((len(a) > 0) & len(b) >
我正在处理具有多个子 JSONObject 的 JSONObject。这是我填写内容的方式: myJson.getJSONObject(CAT_NAME).put(VAR_NAME, var)
想象一下这种情况,我有一个需要检查属性的对象。但是,该对象当前可以具有空值。 如何在一个“if”条件下检查这两个条件? 目前,我必须做这样的事情: if (myObject != null) {
我有一个对象集合,称它们为obj。他们有一个 act() 方法。 act() 方法最终会导致 o 上的 event() observable 调用 onComplete。 链接这些的好方法是什么? 即
假设我有一个列表变量 datalist 存储 10,000 个字符串实体。QTableView 只需要显示其中的一些实体。这就是为什么 QTableView 被指定为 QSortFilterProxy
我正在寻找支持链式 MSI 安装的工具(最好不是 InstallShield,而且最好是便宜/免费的)。我有几个小型安装需要能够单独部署,但也需要作为一个组部署,我不想维护多个安装程序。 看起来我需要
在这种情况下,我想迭代集合中除最后 2 个元素之外的所有元素。 假设我采用了一种奇怪的方式,例如 x.Reverse().Skip(2).Reverse()。 每个 LINQ 操作是否会有效地生成一个
对于javascript来说非常陌生,我有两个html数字选择,包括年份,我想将第二个选择与第一个选择链接起来,这样当我在第一个选择中选择年份时(而第二个选择没有选项)首先),第二个选择应包括从所选数
有人可以向我解释一下为什么以下两个链式函数: // returns zero if okay var resetCounter = function (model) { return new Prom
所以我有 2 个 promise 函数。当第一个函数出现错误时,我希望它显示错误消息。当完成或失败时,我希望他们执行一个finally catch all 函数,但由于某种原因它不起作用。我的代码如下
我有一个函数 const func = () => server.insertPatientSurveyQuestionToDataBase(Store.getPatientID(), SurveyN
(async function() { var a,b; function flush(){ return new Promise(res => {
这个问题已经有答案了: Promise chaining: Use result from previous promise in next then callback [duplicate] (1
这可能不是专业正则表达式理解的问题。唯一重要的是因为我正在运行多个链式替换命令,这些命令会影响文本文件中的某些相同文本。我还想象在替换之前,根据分隔符词(需要多次替换)的使用方式对 txt 文件进行分
我正在尝试构建一组类来定义 OSI 堆栈中协议(protocol)的分层属性...从抽象意义上讲,我只需要从父 python 类继承属性,但我需要能够调用整个类链一次...所以,我正在寻找这样的东西.
我正在努力兑现 promise ,到目前为止我偶然发现了这一点: new Promise((resolve, reject) => { setTimeout(() => { r
我试图理解 promise ,我需要链接它们并装饰来自不同端点的对象宽度数据。 例如: 我的 Node-express 应用程序中有这个 //controller.js export const ge
我是一名优秀的程序员,十分优秀!