<ruby id="bdb3f"></ruby>

    <p id="bdb3f"><cite id="bdb3f"></cite></p>

      <p id="bdb3f"><cite id="bdb3f"><th id="bdb3f"></th></cite></p><p id="bdb3f"></p>
        <p id="bdb3f"><cite id="bdb3f"></cite></p>

          <pre id="bdb3f"></pre>
          <pre id="bdb3f"><del id="bdb3f"><thead id="bdb3f"></thead></del></pre>

          <ruby id="bdb3f"><mark id="bdb3f"></mark></ruby><ruby id="bdb3f"></ruby>
          <pre id="bdb3f"><pre id="bdb3f"><mark id="bdb3f"></mark></pre></pre><output id="bdb3f"></output><p id="bdb3f"></p><p id="bdb3f"></p>

          <pre id="bdb3f"><del id="bdb3f"><progress id="bdb3f"></progress></del></pre>

                <ruby id="bdb3f"></ruby>

                ThinkChat2.0新版上線,更智能更精彩,支持會話、畫圖、視頻、閱讀、搜索等,送10W Token,即刻開啟你的AI之旅 廣告
                之前提到過Flume的Agent由三部分組成:Source、Channel、Sink。下面是使用Flume的過程。 (1)創建一個`.conf`文件,編寫Agent、Source、Channel、Sink的配置信息。 `netcat_source.conf` ```xml ############## 1. Agent初始化 ############ # agent為Agent的名字,可以隨便命名 # s1、c1、sk1是在該agent下的Source、Channel、Sink,也可以隨便命名 agent.sources = s1 agent.channels = c1 agent.sinks = sk1 ############## 2. Source配置 ############# # 設置Source的類型、ip、端口 agent.sources.s1.type = netcat agent.sources.s1.bind = hadoop101 # 我機器的主機名為hadoop101,你也可以使用localhost代替 agent.sources.s1.port = 5678 # 將s1發送到c1通道上 agent.sources.s1.channels = c1 ############## 3. Sink配置 ############# # 設置Sink類型為logger模式 agent.sinks.sk1.type = logger # Sink從c1通道獲取數據 agent.sinks.sk1.channel = c1 ############ 4. Channel配置 ############ # 設置Channel為內存模式,容量1000,傳輸參數100 agent.channels.c1.type = memory agent.channels.c1.capacity = 1000 agent.channels.c1.transactionCapacity = 100 ``` (2)啟動Agent服務 ```shell -- 切換到flume的根目錄下執行下面的語句。當然如果你已經配置了環境變量則就不需要了 bin/flume-ng agent -c conf -f myconf/netcat_source.conf --name agent -Dflume.root.logger=INFO,console ``` (3)發送測試數據 開啟后輸入 hello flume、hello world。 ```shell [root@hadoop101 /]# telnet hadoop101 5678 Trying 192.168.64.138... Connected to hadoop101. Escape character is '^]'. hello flume OK hello world OK ``` 如果沒有安裝`telnet`命令,可以如下安裝。 ```shell -- 查看telnet命令有哪些 [root@hadoop101 /]# yum list telnet* telnet.x86_64 1:0.17-66.el7 updates telnet-server.x86_64 1:0.17-66.el7 -- 只需安裝telnet.x86_64即可 [root@hadoop101 /]# yum install telnet.x86_64 ``` (4)然后你就可以在開啟Agent服務的窗口中看到發送過來的數據了。 ![](https://img.kancloud.cn/de/fa/defaeda632be37497ac1e70b6cc4543d_1059x116.png) <br/> 以上就是Flume的使用過程。
                  <ruby id="bdb3f"></ruby>

                  <p id="bdb3f"><cite id="bdb3f"></cite></p>

                    <p id="bdb3f"><cite id="bdb3f"><th id="bdb3f"></th></cite></p><p id="bdb3f"></p>
                      <p id="bdb3f"><cite id="bdb3f"></cite></p>

                        <pre id="bdb3f"></pre>
                        <pre id="bdb3f"><del id="bdb3f"><thead id="bdb3f"></thead></del></pre>

                        <ruby id="bdb3f"><mark id="bdb3f"></mark></ruby><ruby id="bdb3f"></ruby>
                        <pre id="bdb3f"><pre id="bdb3f"><mark id="bdb3f"></mark></pre></pre><output id="bdb3f"></output><p id="bdb3f"></p><p id="bdb3f"></p>

                        <pre id="bdb3f"><del id="bdb3f"><progress id="bdb3f"></progress></del></pre>

                              <ruby id="bdb3f"></ruby>

                              哎呀哎呀视频在线观看