我的logstash input 配置文件如下
input {
jdbc {
type => "testdb"
jdbc_driver_library => "/app/sqljdbc_6.0/enu/sqljdbc42.jar"
jdbc_driver_class => "com.microsoft.sqlserver.jdbc.SQLServerDriver"
jdbc_connection_string => "jdbc:sqlserver://192.168.**.**:1433"
jdbc_user => "******"
jdbc_password => "**********"
jdbc_paging_enabled => "true"
schedule => "* * * * *"
statement_filepath => "/app/age_config.d/sqlserver_10.1.2.37.sql"
}}
我希望,当数据库testdb有新的数据写入时,logstash自动读取新写入的数据
input {
jdbc {
type => "testdb"
jdbc_driver_library => "/app/sqljdbc_6.0/enu/sqljdbc42.jar"
jdbc_driver_class => "com.microsoft.sqlserver.jdbc.SQLServerDriver"
jdbc_connection_string => "jdbc:sqlserver://192.168.**.**:1433"
jdbc_user => "******"
jdbc_password => "**********"
jdbc_paging_enabled => "true"
schedule => "* * * * *"
statement_filepath => "/app/age_config.d/sqlserver_10.1.2.37.sql"
}}
我希望,当数据库testdb有新的数据写入时,logstash自动读取新写入的数据
解决方案 »
- 谁能很形象地解释一下云计算
- 求解:nova是如何把公钥传送到VM里面
- 完全虚拟化和部分虚拟化的IO流程
- Spark调用程序出错
- spark1.5.2 spark-shell 启动时一定要启动hadoop,怎么解决,谢谢!
- Spark graphx 可扩展性(scalability)如何复现?
- 为何HyperV和ESXi每当虚拟机启动,母机磁盘空间就会减少?虚拟内存理应是存入在虚拟机里啊
- java 提交spark任务,出现ExitCodeException exitCode=10的错误
- 讨论: 关于广播变量的用法
- kubernetes可否感知仓库image的变化后自动部署
- 在IntelliJ IDEA上调试spark
- Spark 学习如何入门?
新增的时候能读取
修改的时候也能监听到。
这个例子太特殊了,情况都是预先安排好一样~
如果在中间插入一条数据,应该不行吧?有没有直接是sqlserver的内部机制呢?