Post 批量请求 API 给出状态代码 406，如何解决？

Question

我使用的是Elasticsearch 6.1版本我的数据附加正确，我在请求末尾添加“\n”。

我的代码如下：

def insert_in_bulk(self, filee, rtype):
    U = urljoin(self.args.host, "/_bulk")
    body = []
    f = open(filee)
    for line in f:
        action = {
                'index' :{
                '_index' : self.args.index,
                '_type' : rtype,
                  }
                }
        item = {
            'word' : line.strip()
            }

        body.append(json.dumps(action))
        body.append(json.dumps(item))

    f.close()

    body = '\n'.join(body)+'\n'
    success = False
    try:
        r = requests.post(U, data=body)
        self.log.info("after request")
        if r.status_code == 200:
            success = True
        r = r.json()
        self.log.info("inserted %s items of type = %s", self.args.index , rtype)
    except (SystemExit, KeyboardInterrupt): raise
    except:
          self.log.exception("during bulk index")

    if not success:
             self.log.error("failed to index records of type = %s", rtype)

我正在使用 python 连接到弹性搜索。

我从中得到了答案link Bulk index document from JSON file into ElasticSearch

我必须将 header 作为 application/x-ndjson 传递给请求。

Answer 1

虽然问这个问题已经有一段时间了，但我想提供一个在大多数情况下对我有用的解决方案，

def insert_in_bulk(self, filee, rtype):
    U = urljoin(self.args.host, "/_bulk")
    body = []
    f = open(filee)
    for line in f:
        action = {
                'index' :{
                '_index' : self.args.index,
                '_type' : rtype,
                  }
                }
        item = {
            'word' : line.strip()
            }

        body.append(json.dumps(action))
        body.append(json.dumps(item))

    f.close()


    payload = ""
    for l in body:
        payload = payload + f"{l} \n"
    data = payload.encode('utf-8')

    r = requests.post(U, data=data, headers={"Content-Type": "application/x-ndjson"})
    print(r.text)

Post 批量请求 API 给出状态代码 406，如何解决？

Post request for bulk API is giving status code of 406, How to resolve it?

elasticsearch

elasticsearch-bulk-api