input {
stdin {}
jdbc {
# 多表同步时,表类型区分,建议命名为“库名_表名”,每个jdbc模块需对应一个type;
type => "b_cover_bilibili"
}
}
# output模块的type需和jdbc模块的type一致
if [type] == "b_cover_bilibili" {
elasticsearch {
# host => "192.168.1.1"
# port => "9200"
# 配置ES集群地址
hosts => ["127.0.0.1:9200"]
index => "bindex"
# 数据唯一索引(建议使用数据库KeyID)
#document_id => "%{id}"
}
}
代码如上,当去掉if判断,数据可以写入es,加上之后,就没有写入。
5 个回复
zqc0512 - andy zhou
赞同来自:
多半是空格与TAB键的关系 这玩意格式要求很严格的。
zqc0512 - andy zhou
赞同来自:
xjar
赞同来自:
Memento - Memento
赞同来自:
xiaobai
赞同来自: