恭喜

@c4923 隔了这么多年居然看到有人推荐《隐杀》 这小说忘了高中还是大学看的了，挺好看，后面还重看过一遍

@NeedMe123456 不是，我用的 v2rayN

看下来还以为一切顺利呢。。OP 还是高兴太早了，公司都从仲裁拖到二审，还是有概率继续拖的，拖不付钱、拖强制执行，祝顺利，早日拿到钱（来自一个历时一年半仍没拿到钱的人

@wss1214 很多位面都呆过，现在专心玩道年号了

@wss1214 有的道友，有的

预约系统、访客系统，曾经给某个大国企做过一个小程序，流程跟你这个描述一样的。来访的人提交来访时间，企业内有权限的人审核通过，来访人就可以直接扫二维码，校验通过了就直接给进了。

怀疑是因为 OP 没讲清楚自家的真实情况，评论里倒是一溜烟都在劝退不要零冷水。
我家是因为厨房和卫生间不在隔壁，跨了一个客厅，为了冬天洗澡不要放那么久冷水，以及洗一半关水再开水之后不至于再冷那么一段，所以装了 美的 的零冷水燃气热水器。
OP 讲的那些功能，美的 现在所谓的“智能化”，都有，家电可以连 wifi ，你在手机上可以一键开启，也可以设置定时。
就这样。

@Michelangelono 前一阵也是和女朋友讨论了这个需求，因为家里养了十几盆花，讨论的时候我就说这类小程序应该已经有人做了，果不其然搜到了一个“养花浇水助手”，里面有基本的功能，自己添加一盆花，手动记录浇水、施肥、打药、换土等操作。

根据天气自动推测这个功能我当时也设想过，比如获取用户定位，自动获取当地天气，包括温湿度、降水等等，最后麻烦的其实就是从哪里得到一个“标准”，用于程序计算下一次是什么时候，不同品种的花、不同纬度、不同海拔、甚至不同大小的盆/土质都能影响这个“标准”，最终也是不了了之吧，夏天嘛。。早晚都得各浇一次花的。。

帮忙能帮到什么程度，大多无非就是走个内推，先把简历扔到他们内部罢了

感觉像是个 AB 问题。。

先确认下，这 1W 人是真的都需要访问到 ES 吗，用缓存转移走部分重复请求或者没必要的请求吧

@NelsonZhao 妙啊

乱点一通之后网络异常了，没有天气预报了 : )

怎么点进来跟昨天那个被骗的哥们不太一样啊

双十一刚买两个空调，本来预备主卧美的 1.5 匹，次卧美的大 1 匹，临买之前看了网上的推荐，打算换成华凌的神机，被女朋友一阵唠叨，不是一线大牌（我们这里确实当年没听过华凌这个老品牌），别制热不好、售后不好之类的，最终主卧依然买了美的的，次卧我换成了华凌 HE1 Pro ，还真没想到制热还有个隐藏的电辅热问题。。感觉到时候要被骂了，还不如买美的

@cgzwxx 「广东 彩礼 1w3 千 8 返 1w 。。。」
大哥，你这样打数字不嫌累么

确实经常遇到这个现象，刷着刷着中间消失一条，再往下拉它又出现了。。

@iian 简单写了个，测试了下可以用，但只能读本地文件确实没直接实时读 redis 方便。

```
input {
file {
path => "D:/logstash-test/input.txt"
}
}

filter {
ruby {
init => '
# 引入 json ，方便操作
require "json"

# 从本地文件中读取，解析后初始化一个 hash ，key 为 userId ，value 为部门 id
@@userDepMap = Hash.new
File.open("D:/logstash-test/filter.txt", "r").each_line do |line|
userDepArray = line.split(",")
@@userDepMap[userDepArray[0]] = userDepArray[1]
end
'
code => '
# 从 message 中拿到消息本身，转 json
msg = event.get("message")
msgJson = JSON.parse(msg)

# 从消息中拿到 userId ，从 hash 中找到对应的部门
user = msgJson["user"].to_s
dep = @@userDepMap[user]

# 将部门保存到消息 json 中
msgJson["dep"] = dep

# 将最新的 json 转字符串，重新设置回 event 中
event.set("message", JSON.generate(msgJson))
'
}
}

output {
stdout {

}
file {
path => "D:/logstash-test/output.txt"
}
}

```

如果决定使用 kafka -> logstash -> elasticsearch 的方案，结合我以前的经验，大概率是可以在 logstash 这一环节补充账号对应的部门信息的（最近几年没怎么实际用过 logstash 了，不敢打保票）。

先回答你的两种方式：

第一种，多个 input 同时读取，这种是不可行的，对多个 input 来说，它们采集到的数据是相互独立的，没有办法结合。

第二种，es 应该要新增部门字段，但这个字段比较难在写入文档的时候从账号关联到部门，印象里 es 有个 script 脚本功能，但好像都是用在更新、查询的时候，能不能用在文档写入阶段就不懂了（→_→ 有没有大佬有实际应用的案例能长长见识。

最后，关于怎么实现账号找部门：logstash 的插件分三类，input filter output ，可以尝试 logstash-filter-ruby 这个 filter 插件来写 ruby 代码。

1. 如果 input 插件读取到的日志信息是 json 格式的，可以用一下 logstash-filter-json 插件，将内容先解析出来。

2. logstash-filter-ruby 插件中拿到账号，如果可以将账号和部门信息存在文件里，就可以写 ruby 代码读取本地文件，找到部门，将部门字段同时写进 logstash 的 event 对象里。

3. filter 结束，output 环节照常，es 中新增一个部门字段，写入即可。