ジオタイルグリッド集約

複数のバケット集約で、geo_pointgeo_shape の値をグリッドを表すバケットにグループ化します。結果として得られるグリッドはスパースであり、一致するデータを持つセルのみを含みます。各セルは、多くのオンラインマップサイトで使用される[https://en.wikipedia.org/wiki/Tiled_web_map]に対応しています。各セルは「{zoom}/{x}/{y}」形式でラベル付けされ、ここでzoomはユーザー指定の精度に等しいです。

  • 高精度キーはxおよびyの範囲が大きく、わずかな面積をカバーするタイルを表します。
  • 低精度キーはxおよびyの範囲が小さく、各タイルが大きな面積をカバーします。

精度(ズーム)が地上のサイズにどのように相関するかについては、ズームレベルのドキュメントを参照してください。この集約の精度は0から29の間で、両端を含みます。

長さ29の最高精度のジオタイルは、10cm x 10cm未満の土地をカバーするセルを生成し、高精度のリクエストはRAMおよび結果サイズの観点から非常にコストがかかる可能性があります。高い詳細レベルを要求する前に、集約を小さな地理的エリアにフィルタリングする方法については、以下の例を参照してください。

  1. ## シンプルな低精度リクエスト
  2. #### Python
  3. ``````python
  4. resp = client.indices.create(
  5. index="museums",
  6. mappings={
  7. "properties": {
  8. "location": {
  9. "type": "geo_point"
  10. }
  11. }
  12. },
  13. )
  14. print(resp)
  15. resp1 = client.bulk(
  16. index="museums",
  17. refresh=True,
  18. operations=[
  19. {
  20. "index": {
  21. "_id": 1
  22. }
  23. },
  24. {
  25. "location": "POINT (4.912350 52.374081)",
  26. "name": "NEMO Science Museum"
  27. },
  28. {
  29. "index": {
  30. "_id": 2
  31. }
  32. },
  33. {
  34. "location": "POINT (4.901618 52.369219)",
  35. "name": "Museum Het Rembrandthuis"
  36. },
  37. {
  38. "index": {
  39. "_id": 3
  40. }
  41. },
  42. {
  43. "location": "POINT (4.914722 52.371667)",
  44. "name": "Nederlands Scheepvaartmuseum"
  45. },
  46. {
  47. "index": {
  48. "_id": 4
  49. }
  50. },
  51. {
  52. "location": "POINT (4.405200 51.222900)",
  53. "name": "Letterenhuis"
  54. },
  55. {
  56. "index": {
  57. "_id": 5
  58. }
  59. },
  60. {
  61. "location": "POINT (2.336389 48.861111)",
  62. "name": "Musée du Louvre"
  63. },
  64. {
  65. "index": {
  66. "_id": 6
  67. }
  68. },
  69. {
  70. "location": "POINT (2.327000 48.860000)",
  71. "name": "Musée d'Orsay"
  72. }
  73. ],
  74. )
  75. print(resp1)
  76. resp2 = client.search(
  77. index="museums",
  78. size="0",
  79. aggregations={
  80. "large-grid": {
  81. "geotile_grid": {
  82. "field": "location",
  83. "precision": 8
  84. }
  85. }
  86. },
  87. )
  88. print(resp2)
  89. `

Ruby

  1. response = client.indices.create(
  2. index: 'museums',
  3. body: {
  4. mappings: {
  5. properties: {
  6. location: {
  7. type: 'geo_point'
  8. }
  9. }
  10. }
  11. }
  12. )
  13. puts response
  14. response = client.bulk(
  15. index: 'museums',
  16. refresh: true,
  17. body: [
  18. {
  19. index: {
  20. _id: 1
  21. }
  22. },
  23. {
  24. location: 'POINT (4.912350 52.374081)',
  25. name: 'NEMO Science Museum'
  26. },
  27. {
  28. index: {
  29. _id: 2
  30. }
  31. },
  32. {
  33. location: 'POINT (4.901618 52.369219)',
  34. name: 'Museum Het Rembrandthuis'
  35. },
  36. {
  37. index: {
  38. _id: 3
  39. }
  40. },
  41. {
  42. location: 'POINT (4.914722 52.371667)',
  43. name: 'Nederlands Scheepvaartmuseum'
  44. },
  45. {
  46. index: {
  47. _id: 4
  48. }
  49. },
  50. {
  51. location: 'POINT (4.405200 51.222900)',
  52. name: 'Letterenhuis'
  53. },
  54. {
  55. index: {
  56. _id: 5
  57. }
  58. },
  59. {
  60. location: 'POINT (2.336389 48.861111)',
  61. name: 'Musée du Louvre'
  62. },
  63. {
  64. index: {
  65. _id: 6
  66. }
  67. },
  68. {
  69. location: 'POINT (2.327000 48.860000)',
  70. name: "Musée d'Orsay"
  71. }
  72. ]
  73. )
  74. puts response
  75. response = client.search(
  76. index: 'museums',
  77. size: 0,
  78. body: {
  79. aggregations: {
  80. "large-grid": {
  81. geotile_grid: {
  82. field: 'location',
  83. precision: 8
  84. }
  85. }
  86. }
  87. }
  88. )
  89. puts response

Js

  1. const response = await client.indices.create({
  2. index: "museums",
  3. mappings: {
  4. properties: {
  5. location: {
  6. type: "geo_point",
  7. },
  8. },
  9. },
  10. });
  11. console.log(response);
  12. const response1 = await client.bulk({
  13. index: "museums",
  14. refresh: "true",
  15. operations: [
  16. {
  17. index: {
  18. _id: 1,
  19. },
  20. },
  21. {
  22. location: "POINT (4.912350 52.374081)",
  23. name: "NEMO Science Museum",
  24. },
  25. {
  26. index: {
  27. _id: 2,
  28. },
  29. },
  30. {
  31. location: "POINT (4.901618 52.369219)",
  32. name: "Museum Het Rembrandthuis",
  33. },
  34. {
  35. index: {
  36. _id: 3,
  37. },
  38. },
  39. {
  40. location: "POINT (4.914722 52.371667)",
  41. name: "Nederlands Scheepvaartmuseum",
  42. },
  43. {
  44. index: {
  45. _id: 4,
  46. },
  47. },
  48. {
  49. location: "POINT (4.405200 51.222900)",
  50. name: "Letterenhuis",
  51. },
  52. {
  53. index: {
  54. _id: 5,
  55. },
  56. },
  57. {
  58. location: "POINT (2.336389 48.861111)",
  59. name: "Musée du Louvre",
  60. },
  61. {
  62. index: {
  63. _id: 6,
  64. },
  65. },
  66. {
  67. location: "POINT (2.327000 48.860000)",
  68. name: "Musée d'Orsay",
  69. },
  70. ],
  71. });
  72. console.log(response1);
  73. const response2 = await client.search({
  74. index: "museums",
  75. size: 0,
  76. aggregations: {
  77. "large-grid": {
  78. geotile_grid: {
  79. field: "location",
  80. precision: 8,
  81. },
  82. },
  83. },
  84. });
  85. console.log(response2);

コンソール

  1. PUT /museums
  2. {
  3. "mappings": {
  4. "properties": {
  5. "location": {
  6. "type": "geo_point"
  7. }
  8. }
  9. }
  10. }
  11. POST /museums/_bulk?refresh
  12. {"index":{"_id":1}}
  13. {"location": "POINT (4.912350 52.374081)", "name": "NEMO Science Museum"}
  14. {"index":{"_id":2}}
  15. {"location": "POINT (4.901618 52.369219)", "name": "Museum Het Rembrandthuis"}
  16. {"index":{"_id":3}}
  17. {"location": "POINT (4.914722 52.371667)", "name": "Nederlands Scheepvaartmuseum"}
  18. {"index":{"_id":4}}
  19. {"location": "POINT (4.405200 51.222900)", "name": "Letterenhuis"}
  20. {"index":{"_id":5}}
  21. {"location": "POINT (2.336389 48.861111)", "name": "Musée du Louvre"}
  22. {"index":{"_id":6}}
  23. {"location": "POINT (2.327000 48.860000)", "name": "Musée d'Orsay"}
  24. POST /museums/_search?size=0
  25. {
  26. "aggregations": {
  27. "large-grid": {
  28. "geotile_grid": {
  29. "field": "location",
  30. "precision": 8
  31. }
  32. }
  33. }
  34. }

レスポンス:

コンソール結果

  1. {
  2. ...
  3. "aggregations": {
  4. "large-grid": {
  5. "buckets": [
  6. {
  7. "key": "8/131/84",
  8. "doc_count": 3
  9. },
  10. {
  11. "key": "8/129/88",
  12. "doc_count": 2
  13. },
  14. {
  15. "key": "8/131/85",
  16. "doc_count": 1
  17. }
  18. ]
  19. }
  20. }
  21. }

高精度リクエスト

詳細なバケットを要求する際(通常は「ズームイン」マップを表示するため)、geo_bounding_boxのようなフィルターを適用して対象エリアを狭める必要があります。そうしないと、数百万のバケットが作成され、返される可能性があります。

Python

  1. resp = client.search(
  2. index="museums",
  3. size="0",
  4. aggregations={
  5. "zoomed-in": {
  6. "filter": {
  7. "geo_bounding_box": {
  8. "location": {
  9. "top_left": "POINT (4.9 52.4)",
  10. "bottom_right": "POINT (5.0 52.3)"
  11. }
  12. }
  13. },
  14. "aggregations": {
  15. "zoom1": {
  16. "geotile_grid": {
  17. "field": "location",
  18. "precision": 22
  19. }
  20. }
  21. }
  22. }
  23. },
  24. )
  25. print(resp)

Ruby

  1. response = client.search(
  2. index: 'museums',
  3. size: 0,
  4. body: {
  5. aggregations: {
  6. "zoomed-in": {
  7. filter: {
  8. geo_bounding_box: {
  9. location: {
  10. top_left: 'POINT (4.9 52.4)',
  11. bottom_right: 'POINT (5.0 52.3)'
  12. }
  13. }
  14. },
  15. aggregations: {
  16. "zoom1": {
  17. geotile_grid: {
  18. field: 'location',
  19. precision: 22
  20. }
  21. }
  22. }
  23. }
  24. }
  25. }
  26. )
  27. puts response

Js

  1. const response = await client.search({
  2. index: "museums",
  3. size: 0,
  4. aggregations: {
  5. "zoomed-in": {
  6. filter: {
  7. geo_bounding_box: {
  8. location: {
  9. top_left: "POINT (4.9 52.4)",
  10. bottom_right: "POINT (5.0 52.3)",
  11. },
  12. },
  13. },
  14. aggregations: {
  15. zoom1: {
  16. geotile_grid: {
  17. field: "location",
  18. precision: 22,
  19. },
  20. },
  21. },
  22. },
  23. },
  24. });
  25. console.log(response);

コンソール

  1. POST /museums/_search?size=0
  2. {
  3. "aggregations": {
  4. "zoomed-in": {
  5. "filter": {
  6. "geo_bounding_box": {
  7. "location": {
  8. "top_left": "POINT (4.9 52.4)",
  9. "bottom_right": "POINT (5.0 52.3)"
  10. }
  11. }
  12. },
  13. "aggregations": {
  14. "zoom1": {
  15. "geotile_grid": {
  16. "field": "location",
  17. "precision": 22
  18. }
  19. }
  20. }
  21. }
  22. }
  23. }

レスポンス:

コンソール結果

  1. {
  2. ...
  3. "aggregations": {
  4. "zoomed-in": {
  5. "doc_count": 3,
  6. "zoom1": {
  7. "buckets": [
  8. {
  9. "key": "22/2154412/1378379",
  10. "doc_count": 1
  11. },
  12. {
  13. "key": "22/2154385/1378332",
  14. "doc_count": 1
  15. },
  16. {
  17. "key": "22/2154259/1378425",
  18. "doc_count": 1
  19. }
  20. ]
  21. }
  22. }
  23. }
  24. }

追加のバウンディングボックスフィルタリングを伴うリクエスト

geotile_grid集約は、提供された境界と交差するセルを考慮するboundsパラメータをオプションでサポートしています。boundsパラメータは、geo-bounding boxクエリと同じbounds形式を受け入れます。このバウンディングボックスは、集約前にポイントをフィルタリングするための追加のgeo_bounding_boxクエリとともに、またはそれなしで使用できます。これは独立したバウンディングボックスであり、追加のgeo_bounding_boxクエリと交差したり、等しい場合や、離れている場合があります。

Python

  1. resp = client.search(
  2. index="museums",
  3. size="0",
  4. aggregations={
  5. "tiles-in-bounds": {
  6. "geotile_grid": {
  7. "field": "location",
  8. "precision": 22,
  9. "bounds": {
  10. "top_left": "POINT (4.9 52.4)",
  11. "bottom_right": "POINT (5.0 52.3)"
  12. }
  13. }
  14. }
  15. },
  16. )
  17. print(resp)

Ruby

  1. response = client.search(
  2. index: 'museums',
  3. size: 0,
  4. body: {
  5. aggregations: {
  6. "tiles-in-bounds": {
  7. geotile_grid: {
  8. field: 'location',
  9. precision: 22,
  10. bounds: {
  11. top_left: 'POINT (4.9 52.4)',
  12. bottom_right: 'POINT (5.0 52.3)'
  13. }
  14. }
  15. }
  16. }
  17. }
  18. )
  19. puts response

Js

  1. const response = await client.search({
  2. index: "museums",
  3. size: 0,
  4. aggregations: {
  5. "tiles-in-bounds": {
  6. geotile_grid: {
  7. field: "location",
  8. precision: 22,
  9. bounds: {
  10. top_left: "POINT (4.9 52.4)",
  11. bottom_right: "POINT (5.0 52.3)",
  12. },
  13. },
  14. },
  15. },
  16. });
  17. console.log(response);

コンソール

  1. POST /museums/_search?size=0
  2. {
  3. "aggregations": {
  4. "tiles-in-bounds": {
  5. "geotile_grid": {
  6. "field": "location",
  7. "precision": 22,
  8. "bounds": {
  9. "top_left": "POINT (4.9 52.4)",
  10. "bottom_right": "POINT (5.0 52.3)"
  11. }
  12. }
  13. }
  14. }
  15. }

レスポンス:

コンソール結果

  1. {
  2. ...
  3. "aggregations": {
  4. "tiles-in-bounds": {
  5. "buckets": [
  6. {
  7. "key": "22/2154412/1378379",
  8. "doc_count": 1
  9. },
  10. {
  11. "key": "22/2154385/1378332",
  12. "doc_count": 1
  13. },
  14. {
  15. "key": "22/2154259/1378425",
  16. "doc_count": 1
  17. }
  18. ]
  19. }
  20. }
  21. }

geo_shapeフィールドの集約

@Geoshapeフィールドの集約は、ポイントの場合とほぼ同様に機能しますが、単一の形状が複数のタイルでカウントされる可能性があります。形状の任意の部分がそのタイルと交差する場合、その形状は一致する値のカウントに寄与します。以下はこれを示す画像です:

geoshape grid

オプション

field (必須、文字列) インデックスされたgeo-pointまたはgeo-shape値を含むフィールド。
明示的にgeo_pointまたはgeo_shapeフィールドとしてマッピングされている必要があります。
フィールドが配列を含む場合、geotile_gridはすべての配列値を集約します。
precision (オプション、整数) 結果のセル/バケットを定義するために使用されるキーの整数ズーム。
デフォルトは7です。[0,29]の外の値は拒否されます。
bounds (オプション、オブジェクト) 各バケット内のgeo-pointsまたはgeo-shapesをフィルタリングするために使用されるバウンディングボックス。
geo-bounding box queryと同じバウンディングボックス形式を受け入れます。
size (オプション、整数) 返されるバケットの最大数。デフォルトは10,000です。
結果がトリミングされる場合、バケットは含まれるドキュメントの量に基づいて優先されます。
shard_size (オプション、整数) 各シャードから返されるバケットの数。デフォルトはmax(10,(size x number-of-shards))で、最終結果のトップセルのより正確なカウントを可能にします。各シャードは異なるトップ結果の順序を持つ可能性があるため、ここでの数を大きくすることで不正確なカウントのリスクが減りますが、パフォーマンスコストが発生します。