気象データをストリーミングするように Flume を構成しています。以下に示すように Flume エージェントを作成しました。
WeatherAgent.sources= 天気
WeatherAgent.sinks = hdfs-write
WeatherAgent.channels= メモリーチャネル
WeatherAgent.sources.Weather.type = 天気
WeatherAgent.sources.Weather.bind = api.openweathermap.org/data/2.5/forecast/city?id=524901&APPID=************
WeatherAgent.sources.Weather.port = 11111
WeatherAgent.sinks.hdfs-write.type = hdfs
WeatherAgent.sinks.hdfs-write.hdfs.path = hdfs://localhost:8020/user/hadoop/flume
WeatherAgent.sinks.hdfs-write.rollInterval = 30
WeatherAgent.sinks.hdfs-write.hdfs.writeFormat=テキスト
WeatherAgent.sinks.hdfs-write.hdfs.fileType=データストリーム
WeatherAgent.channels.memoryChannel.type = メモリ
WeatherAgent.channels.memoryChannel.capacity=10000
WeatherAgent.sources.Weather.channels=memoryChannel
WeatherAgent.sinks.hdfs-write.channel=memoryChannel
私はエラーが発生しています
気象エージェントに有効なチャネルが含まれていないため、無効になっています。
私はflumeを初めて使用します。エージェント構成ファイルに追加するすべてのパラメータがわかりません。書かれたエージェントが正しいか間違っているかさえわかりません。これを解決するのを手伝ってください。カスタムまたは新しいエージェントを作成するためのヘルプ リンクがある場合は、投稿してください。
前もって感謝します
スヨグ