在Fred Georges谈到微服务架构时,他提到使用Kafka作为高速总线(他称为急流)并将多个0mq实例(称为河流)连接到它.这里可以看到这张幻灯片.
任何人都可以分享如何最好地实现此绑定?
我有一个包含格式错误的JSON的字符串,它提供给我,其中键缺少引号.JSON的结构不受我的控制,所以我需要使用我拥有的东西.我已经找到了解析在PL中使用JavaScript中的格式错误的JSON工作的解决方案,但是其中一个值包含RegEx匹配的URL并将其转换为另一个键,如值,从而导致真正损坏的JSON.有任何想法吗?
我也看过jsonrepair,但在那里没有取得多大成功.
我正在使用Mongoose和Bluebird,并且在使用包含时间戳排序的查询时遇到错误.我试图只检索最近的条目.使用内置的Promises时查询有效.
有任何想法吗?谢谢!
var Promise = require("bluebird"),
mongoose = require('mongoose');
var Item = Promise.promisifyAll(mongoose.model("Item"));
Promise.promisifyAll(Item.prototype);
var connect = function () {
var options = { server: { socketOptions: { keepAlive: 1 } } };
var mongoUrl = "mongodb://" + config.mongo.host + ":" + config.mongo.port + "/" + config.mongo.db;
mongoose.connect(mongoUrl, options);
};
connect();
Item.findAsync({item_id: "03010200400000a0bf00210"}).sort({ts:-1}).limit(1);
Run Code Online (Sandbox Code Playgroud)
Possibly unhandled TypeError: Object [object Promise] has no method 'sort'
at Object.module.exports.process (/Source/updater2/checkAndUpdate.js:88:75)
at /Source/tellme/updater2/test1.js:25:20
at tryCatch1 (/Source/updater2/node_modules/bluebird/js/main/util.js:43:21)
at Promise$_callHandler [as _callHandler] (/Source/updater2/node_modules/bluebird/js/main/promise.js:627:13)
at Promise$_settlePromiseFromHandler [as _settlePromiseFromHandler] …Run Code Online (Sandbox Code Playgroud) node.js ×2
apache-kafka ×1
bluebird ×1
javascript ×1
json ×1
mongoose ×1
nanomsg ×1
regex ×1
zeromq ×1