欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

Flume監(jiān)聽(tīng)oracle表增量的步驟詳解

 更新時(shí)間：2018年07月19日 08:36:12   作者：Ginoy  
這篇文章主要介紹了Flume監(jiān)聽(tīng)oracle表增量的步驟詳解,非常不錯(cuò)，具有一定的參考借鑒價(jià)值，需要的朋友可以參考下

需求：獲取oracle表增量信息，發(fā)送至udp514端口，支持ip配置

步驟：

（1）需要的jar  oracle的 odbc5.jar（oracle安裝目錄  /jdbc/lib下查找）

（2）flume的開(kāi)源包flume-ng-sql-source-1.4.3.jar  最新的好像是1.5的 小版本記不住了 這個(gè)下載地址直接csdn上就有

這兩個(gè)jar 都拷貝到flume的lib下

（3）flume配置文件

a1.sources = r1
a1.sinks = k1
a1.channels = c1
#接收syslog配置
#a1.sources.r1.type = syslogudp
#a1.sources.r1.port = 514
#a1.sources.r1.host = 0.0.0.0
###########sql source#################
a1.sources.r1.type = org.keedio.flume.source.SQLSource
a1.sources.r1.hibernate.connection.url = jdbc:oracle:thin:@10.9.224.36:1521/soc
# Hibernate Database connection properties
a1.sources.r1.hibernate.connection.user = soc_app
a1.sources.r1.hibernate.connection.password = soc_app
a1.sources.r1.hibernate.connection.autocommit = true
a1.sources.r1.hibernate.dialect = org.hibernate.dialect.Oracle10gDialect
a1.sources.r1.hibernate.connection.driver_class = oracle.jdbc.driver.OracleDriver
a1.sources.r1.run.query.delay=1
a1.sources.r1.status.file.path = /usr/local/flume
a1.sources.r1.status.file.name = a1.sqlSource.status
# Custom query
a1.sources.r1.start.from = '2017-07-31 07:06:20'
a1.sources.r1.custom.query = SELECT CHR(39)||TO_CHAR(CREATETIME,'YYYY-MM-DD HH24:MI:SS')||CHR(39),MSG FROM FLUME_NG_SQL_SOURCE WHERE CREATETIME > TO_DATE($@$,'YYYY-MM-DD HH24:MI:SS') ORDER BY CREATETIME ASC
a1.sources.r1.batch.size = 6000
a1.sources.r1.max.rows = 1000
a1.sources.r1.hibernate.connection.provider_class = org.hibernate.connection.C3P0ConnectionProvider
a1.sources.r1.hibernate.c3p0.min_size=1
a1.sources.r1.hibernate.c3p0.max_size=10
###########sql source#################
#自定義類(lèi)型
a1.sinks.k1.type = com.neusoft.utils.SyslogSink
#配置發(fā)送ip
a1.sinks.k1.destination = 10.9.224.36
a1.channels.c1.type = memory
a1.channels.c1.capacity = 10000
a1.channels.c1.transactionCapacity = 10000
a1.sources.r1.channels = c1
a1.sinks.k1.channel = c1
#啟動(dòng)命令 ./flume-ng agent -c ../conf -f ../conf/flume-sql.conf -n a1 -Dflume.root.logger=INFO,console &

由于是自己定義的sink 在我的博客中也有提到，所以配置了自定義的sink。

總結(jié)

以上所述是小編給大家介紹的Flume監(jiān)聽(tīng)oracle表增量的步驟詳解，希望對(duì)大家有所幫助，如果大家有任何疑問(wèn)請(qǐng)給我留言，小編會(huì)及時(shí)回復(fù)大家的。在此也非常感謝大家對(duì)腳本之家網(wǎng)站的支持！

相關(guān)文章

  • oracle用戶(hù)權(quán)限、角色管理詳解

    oracle用戶(hù)權(quán)限、角色管理詳解

    這篇文章主要介紹了oracle用戶(hù)權(quán)限、角色管理的使用和示例,需要的朋友可以參考下
    2014-04-04
  • Oracle 監(jiān)聽(tīng)器密碼設(shè)置方法(LISTENER)

    Oracle 監(jiān)聽(tīng)器密碼設(shè)置方法(LISTENER)

    在缺省的情況下，任意用戶(hù)不需要使用任何密碼即通過(guò)lsnrctl 工具對(duì)Oracle Listener進(jìn)行操作或關(guān)閉，從而造成任意新的會(huì)話(huà)都將無(wú)法建立連接
    2016-09-09
  • ORACLE應(yīng)用經(jīng)驗(yàn)(1)

    ORACLE應(yīng)用經(jīng)驗(yàn)(1)

    ORACLE應(yīng)用經(jīng)驗(yàn)(1)...
    2007-03-03
  • Oracle重建索引Shell腳本、SQL腳本分享

    Oracle重建索引Shell腳本、SQL腳本分享

    這篇文章主要介紹了Oracle重建索引Shell腳本、SQL腳本分享,索引是提高數(shù)據(jù)庫(kù)查詢(xún)性能的有力武器,定期重建索引是很有必要的事情,需要的朋友可以參考下
    2014-09-09
  • Oracle中SQL*plus常用命令詳解

    Oracle中SQL*plus常用命令詳解

    在 Oracle 11g 數(shù)據(jù)庫(kù)系統(tǒng)中,用戶(hù)對(duì)數(shù)據(jù)庫(kù)的操作主要是通過(guò) SQL*Plus 來(lái)完成的,下面將介紹如何啟動(dòng) SQL*Plus 和如何使用 SQL*Plus 連接到數(shù)據(jù)庫(kù),感興趣的朋友跟隨小編一起看看吧
    2024-01-01
  • Oracle硬解析和軟解析的區(qū)別分析

    Oracle硬解析和軟解析的區(qū)別分析

    我們都知道在Oracle中每條SQL語(yǔ)句在執(zhí)行之前都需要經(jīng)過(guò)解析，這里面又分為軟解析和硬解析。在Oracle中存在兩種類(lèi)型的SQL語(yǔ)句，一類(lèi)為 DDL語(yǔ)句(數(shù)據(jù)定義語(yǔ)言)，就是每次執(zhí)行都需要進(jìn)行硬解析。還有一類(lèi)就是DML語(yǔ)句，他們會(huì)根據(jù)情況選擇要么進(jìn)行硬解析，要么進(jìn)行軟解析。
    2014-08-08
  • Oracle中行列轉(zhuǎn)換有哪些方法

    Oracle中行列轉(zhuǎn)換有哪些方法

    這篇文章主要給大家介紹了關(guān)于Oracle中行列轉(zhuǎn)換有哪些方法的相關(guān)資料,最近在工作中遇到了涉及到數(shù)據(jù)庫(kù)行列之間相互轉(zhuǎn)換的問(wèn)題,所以這里給大家總結(jié)介紹下,需要的朋友可以參考下
    2023-08-08
  • oracle中日期與字符串的相互轉(zhuǎn)化的方法詳解

    oracle中日期與字符串的相互轉(zhuǎn)化的方法詳解

    Oracle數(shù)據(jù)庫(kù)系統(tǒng)是世界上最廣泛使用的數(shù)據(jù)庫(kù)管理系統(tǒng)之一,尤其在企業(yè)級(jí)應(yīng)用中占據(jù)主導(dǎo)地位,其中,日期函數(shù)是Oracle SQL中非常重要的組成部分,它們用于處理和操作日期和時(shí)間數(shù)據(jù),本文將給大家介紹oracle中日期與字符串的相互轉(zhuǎn)化的方法,需要的朋友可以參考下
    2024-09-09
  • oracle19c卸載教程的超詳細(xì)教程

    oracle19c卸載教程的超詳細(xì)教程

    Oracle安裝失敗,如何卸載呢?下面這篇文章主要給大家介紹了關(guān)于oracle19c卸載教程的超詳細(xì)教程,文中通過(guò)圖文介紹的非常詳細(xì),需要的朋友可以參考下
    2023-01-01
  • Oracle Decode()函數(shù)使用技巧分享

    Oracle Decode()函數(shù)使用技巧分享

    decode()函數(shù)是ORACLE PL/SQL是功能強(qiáng)大的函數(shù)之一，目前還只有ORACLE公司的SQL提供了此函數(shù)，其他數(shù)據(jù)庫(kù)廠商的SQL實(shí)現(xiàn)還沒(méi)有此功能
    2013-05-05

最新評(píng)論