微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦!

【ElasticSearch】踩坑 关于bulk操作报错

【ElasticSearch】踩坑 关于bulk操作报错


1.问题

想要执行批量插入操作

POST /customer/external/_bulk
{"create":{"_id":"1"}}
{
  "key_id":"url_https_18560751222",
  "nodealias": "baidu",
  "taskFinishTime":"1630857697326",
  "result":
    {
      "HTTP_Request":
      {
        "responseTime":89.0
      }
    }
}
{"create":{"_id":"2"}}
{
  "key_id":"url_https_18560751211",
  "nodealias": "bing",
  "taskFinishTime":"1630857697300",
  "result":
  {
    "HTTP_Request":
    {
      "responseTime":109.0
    }
  }
}

报错:

json_e_o_f_exception

"Unexpected end-of-input: expected close marker for Object (start marker at [Source: (ByteArrayInputStream); line: 1, column: 1])\n at [Source: (ByteArrayInputStream); line: 1, column: 2]"

或者

illegal_argument_exception

Malformed action/Metadata line [3], expected START_OBJECT but found [VALUE_STRING]


2.正确写法

万万没想到,_bulk的操作,行为和请求体数据 都是不能换行的。。

POST /customer/external/_bulk
{"create":{"_id":"1"}}
{"key_id":"url_https_18560751222","nodealias": "baidu","taskFinishTime":"1630857697326","result":{"HTTP_Request":{"responseTime":89.0}}}
{"create":{"_id":"2"}}
{"key_id":"url_https_18560751211","nodealias": "bing","taskFinishTime":"1630857697300","result":{"HTTP_Request":{"responseTime":109.0}}}

创建成功

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。

相关推荐