2017-01-04 23 views
0

Устанавливая http-источник для агента flume, я использовал порт 8989. и агент начинает нормально, но когда я делаю запрос на отправку, я получаю status_code 400 и на запрос request status_code 400. Кто-то указал, что я передача ошибочных данных в почтовом запросе. Как я могу узнать, зачем я должен передавать данные. Также я не передаю никакие данные в get. Тем не менее он дает status_code 500.Http-source flum в hdfs не работает.? Код состояния для почтового запроса 400?

`>>> res=requests.get('http://hdp.localdomain:41414') 
>>> res.status_code 
500 
>>> 
>>> res=requests.post('http://hdp.localdomain:41414',data=a) 
>>> res.status_code 
400 
>>> 
a ={ 
    "colorsArray":[{ 
      "colorName":"red", 
      "hexValue":"#f00" 
     }, 
     { 
      "colorName":"green", 
      "hexValue":"#0f0" 
     }, 
     { 
      "colorName":"blue", 
      "hexValue":"#00f" 
     } 

    ] 
} 
` 

a содержит простые данные json. Также кажется, что работает http-источник flume. Поскольку в журнале нет ошибок.

ответ

0

Отправить данные в этом формате

{ "заголовки": { "метки времени": "434324343", "хозяина": "random_host.example.com" }, "тело": "random_body" }

+0

Да, это правильно. Я нашел его в последнее время. Как работает ключ заголовка? Я знаю, что только тело сохраняется как файл в hdf. Можем ли мы использовать заголовки, когда данные тела находятся в hdfs в каком-то файле. –