2

Flume構成ファイルで、このように定義されたTwitter Flumeソースがあります

TwitterAgent.sources.Twitter.type = com.cloudera.flume.source.TwitterSource
TwitterAgent.sources.Twitter.channels = MemChannel
TwitterAgent.sources.Twitter.consumerKey = xxxxx
TwitterAgent.sources.Twitter.consumerSecret = xxx
TwitterAgent.sources.Twitter.accessToken = xxx
TwitterAgent.sources.Twitter.accessTokenSecret = xxx
TwitterAgent.sources.Twitter.keywords = Avengers

「キーワード」プロパティは「アベンジャーズ」にハードコードされています。このプロパティ値を変数にして、flume エージェントを起動するときに渡したいと思いました。位置パラメータを試しましたが、うまくいかないようです。

これを行う方法についてのアイデアはありますか?

4

1 に答える 1

0

はい、プロキシ機能が twitter-source にありません。承認待ちのパッチを提出しました。それまでは、私のバージョンを github から自由にプルしてください。

https://github.com/schmiegelow/flume/blob/trunk/flume-ng-sources/flume-twitter-source/src/main/java/org/apache/flume/source/twitter/TwitterSource.java

乾杯、

エリック

于 2015-04-09T09:28:08.193 に答える