资讯专栏INFORMATION COLUMN

elasticsearch-python-sdk

seal_de / 1153人阅读

摘要:前言这里声明漫谈我们都知道下有的包的,我们也知道下有封装更好的包。当然这种也是优点,但是如果用了下的的的话,你会会发现对于都封装的很好。故此,我对下的包进行了增强对进行封装。这里我的实现也很简单,其实希望有人能有更好的实现。

前言

这里声明: elasticsearch -> es

漫谈

我们都知道Python 下 有es的sdk包的,我们也知道java 下有封装更好的es包。为什么说python 下的就封装不好呢? 其实这个也两说,有人就喜欢这样呢

Python下的es包首先什么都能做,实现功能完全没问题。但是对于 DSL 的话,Python下的es就没有封装了,完全按照es的语法写查询语句。当然这种也是优点,但是如果用了Java下的es 的sdk的话,你会会发现对于DSL 都封装的很好。

至于封不封装DSL,其实也看业务复不复杂,简单的业务,几行的DSL 直接写也没什么,但是如果很长的呢,比如我这样业务的DSL:

</>复制代码

  1. {
  2. "size": 1000,
  3. "query": {
  4. "bool": {
  5. "must": [
  6. {
  7. "term": {
  8. "prod_code": {
  9. "value": "JDB"
  10. }
  11. }
  12. },
  13. {
  14. "bool": {
  15. "must": [],
  16. "must_not": [],
  17. "should": [
  18. {
  19. "bool": {
  20. "must": [],
  21. "must_not": [],
  22. "should": [
  23. {
  24. "query_string": {
  25. "default_field": "rp_content",
  26. "query": "*下了*"
  27. }
  28. },
  29. {
  30. "query_string": {
  31. "default_field": "rp_content",
  32. "query": "*下款*"
  33. }
  34. }
  35. ],
  36. "filter": []
  37. }
  38. },
  39. {
  40. "nested": {
  41. "path": "rp_data",
  42. "query": {
  43. "bool": {
  44. "must": [],
  45. "must_not": [],
  46. "should": [
  47. {
  48. "query_string": {
  49. "default_field": "rp_data.rp_content",
  50. "query": "*下了*"
  51. }
  52. },
  53. {
  54. "query_string": {
  55. "default_field": "rp_data.rp_content",
  56. "query": "*下款*"
  57. }
  58. }
  59. ],
  60. "filter": []
  61. }
  62. }
  63. }
  64. }
  65. ],
  66. "filter": []
  67. }
  68. }
  69. ]
  70. }
  71. }
  72. }

如果是这样的DSL 直接写在代码中,这个也太长了吧,而且这还不是全部,只是一部分,对于这种动态而且复杂的DSL,直接写,会显得太长。

故此,我对Python 下的es包进行了增强 —— 对DSL进行封装。项目请点击:# elasticsearch-python

对于上面DSL 的封装调用结果是这样的:

</>复制代码

  1. prod_code = "JDB"
  2. key = "下了"
  3. value = "下了 | 下款"
  4. bq = bool_query()
  5. bq.must(term_query("prod_code", prod_code))
  6. .must(bool_query()
  7. .should(multi_query_string("rp_content", value))
  8. .should(nested_query("rp_data", multi_query_string("rp_data.rp_content", value)))
  9. )
  10. print(bq)
  11. print(QueryBuilders(bq).size(1000))

这下清爽了很多是吧!

当然这个没写完,对于聚合还没写,而且query也没全部支持,只是把自己用到的给简单封装了下,其实不知道到底有没有人用,没人用自己写再多也就自己玩玩了。这里我的实现也很简单,其实希望有人能有更好的实现。

文章版权归作者所有,未经允许请勿转载,若此文章存在违规行为,您可以联系管理员删除。

转载请注明本文地址:https://www.ucloud.cn/yun/41773.html

相关文章

发表评论

0条评论

最新活动
阅读需要支付1元查看
<