如何从弹性搜索中提取“消息”值？ (DSL)

Question

如何从 elasticsearch 中提取“消息”值？ (DSL)

我试过了。 （我的代码）

-> 我只想提取所有“消息”值。

GET 0503instgram_csv/_search
{
  "query" : {
    "query_string": {
      "default_field": "message",
      "query": ?????????????
    }
  }
}

-> 我想通过保存所有打印出来的“消息”的新字段值来处理数据。

非常感谢您的帮助。

@ESCoder 这是您所说的尝试结果的图片。

{
  "took" : 1,
  "timed_out" : false,
  "_shards" : {
    "total" : 1,
    "successful" : 1,
    "skipped" : 0,
    "failed" : 0
  },
  "hits" : {
    "total" : {
      "value" : 281,
      "relation" : "eq"
    },
    "max_score" : 1.0,
    "hits" : [
      {
        "_index" : "0503instgram_csv",
        "_type" : "_doc",
        "_id" : "zbKQMXkB98wUkKJOL8dT",
        "_score" : 1.0,
        "_source" : {
          "message" : "\"lovablepoetree"
        }
      },
      {
        "_index" : "0503instgram_csv",
        "_type" : "_doc",
        "_id" : "zrKQMXkB98wUkKJOL8dU",
        "_score" : 1.0,
        "_source" : {
          "message" : """내가 아는 사람 중에 최고 셀럽(@hanstar.kim)과 맥주 마심????셀럽과 술이라니....! 성공해따 나자신!!!!!! 그래놓고 사진은 나 혼자 찍어따^.^ 다음번엔 투샷을 찍어보쟈......????"""
        }
      },
      {
        "_index" : "0503instgram_csv",
        "_type" : "_doc",
        "_id" : "z7KQMXkB98wUkKJOL8dU",
        "_score" : 1.0,
        "_source" : {
          "message" : """????????..열정을 응원 합니다. 도대현 드림❤️❤️❤️"""
        }
      },
      {
        "_index" : "0503instgram_csv",
        "_type" : "_doc",
        "_id" : "0LKQMXkB98wUkKJOL8dU",
        "_score" : 1.0,
        "_source" : {
          "message" : "lovablepoetree"
        }
      },
      {
        "_index" : "0503instgram_csv",
        "_type" : "_doc",
        "_id" : "0bKQMXkB98wUkKJOL8dj",
        "_score" : 1.0,
        "_source" : {
          "message" : """좋아요 69개
"""
        }
      },
      {
        "_index" : "0503instgram_csv",
        "_type" : "_doc",
        "_id" : "0rKQMXkB98wUkKJOL8dj",
        "_score" : 1.0,
        "_source" : {
          "message" : """['paulchang1103,Paul Chang (장준성)????????,passionated_man,도대현,luv_____juju,쥬쥬,koonge01,영이,p.s.j___5959,또둔,panchitoyoon,Ye Suk Yoon,hyeriiing__,혤,sunny.gibbab,써니네식탁(sunny Gib-bab),_wjstn_ry_02,전수교(20),sungwoon_jinsik,윤성운????????,t_a_k_3014,????케이,팔로우']
"""
        }
      },
      {
        "_index" : "0503instgram_csv",
        "_type" : "_doc",
        "_id" : "07KQMXkB98wUkKJOL8dj",
        "_score" : 1.0,
        "_source" : {
          "message" : "passionated_man"
        }
      },
      {
        "_index" : "0503instgram_csv",
        "_type" : "_doc",
        "_id" : "1LKQMXkB98wUkKJOL8dj",
        "_score" : 1.0,
        "_source" : {
          "message" : "1일"
        }
      },
      {
        "_index" : "0503instgram_csv",
        "_type" : "_doc",
        "_id" : "1bKQMXkB98wUkKJOL8dj",
        "_score" : 1.0,
        "_source" : {
          "message" : """????????..열정을 응원 합니다. 도대현 드림❤️❤️❤️"""
        }
      },
      {
        "_index" : "0503instgram_csv",
        "_type" : "_doc",
        "_id" : "1rKQMXkB98wUkKJOL8dj",
        "_score" : 1.0,
        "_source" : {
          "message" : """1일답글 달기","lovablepoetree"""
        }
      }
    ]
  }
}

Answer 1

您可以通过source filtering 仅提取message 字段值

GET/_search
{
  "_source": [
    "message"
  ]
}

更新 1：

您可以使用reindex API，仅将message 字段的字段值存储在不同的索引中

POST /_reindex
{
  "source": {
    "index": "old-index",
    "_source": ["message"]
  },
  "dest": {
    "index": "new-index"
  }
}