rollover-index.asciidoc 6.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228
  1. [[indices-rollover-index]]
  2. == Rollover Index
  3. The rollover index API rolls an alias over to a new index when the existing
  4. index is considered to be too large or too old.
  5. The API accepts a single alias name and a list of `conditions`. The alias
  6. must point to a single index only. If the index satisfies the specified
  7. conditions then a new index is created and the alias is switched to point to
  8. the new index.
  9. [source,js]
  10. --------------------------------------------------
  11. PUT /logs-000001 <1>
  12. {
  13. "aliases": {
  14. "logs_write": {}
  15. }
  16. }
  17. # Add > 1000 documents to logs-000001
  18. POST /logs_write/_rollover <2>
  19. {
  20. "conditions": {
  21. "max_age": "7d",
  22. "max_docs": 1000
  23. }
  24. }
  25. --------------------------------------------------
  26. // CONSOLE
  27. // TEST[setup:huge_twitter]
  28. // TEST[s/# Add > 1000 documents to logs-000001/POST _reindex?refresh\n{"source":{"index":"twitter"},"dest":{"index":"logs-000001"}}/]
  29. <1> Creates an index called `logs-0000001` with the alias `logs_write`.
  30. <2> If the index pointed to by `logs_write` was created 7 or more days ago, or
  31. contains 1,000 or more documents, then the `logs-000002` index is created
  32. and the `logs_write` alias is updated to point to `logs-000002`.
  33. The above request might return the following response:
  34. [source,js]
  35. --------------------------------------------------
  36. {
  37. "acknowledged": true,
  38. "shards_acknowledged": true,
  39. "old_index": "logs-000001",
  40. "new_index": "logs-000002",
  41. "rolled_over": true, <1>
  42. "dry_run": false, <2>
  43. "conditions": { <3>
  44. "[max_age: 7d]": false,
  45. "[max_docs: 1000]": true
  46. }
  47. }
  48. --------------------------------------------------
  49. // TESTRESPONSE
  50. <1> Whether the index was rolled over.
  51. <2> Whether the rollover was dry run.
  52. <3> The result of each condition.
  53. [float]
  54. === Naming the new index
  55. If the name of the existing index ends with `-` and a number -- e.g.
  56. `logs-000001` -- then the name of the new index will follow the same pattern,
  57. incrementing the number (`logs-000002`). The number is zero-padded with a length
  58. of 6, regardless of the old index name.
  59. If the old name doesn't match this pattern then you must specify the name for
  60. the new index as follows:
  61. [source,js]
  62. --------------------------------------------------
  63. POST /my_alias/_rollover/my_new_index_name
  64. {
  65. "conditions": {
  66. "max_age": "7d",
  67. "max_docs": 1000
  68. }
  69. }
  70. --------------------------------------------------
  71. // CONSOLE
  72. // TEST[s/^/PUT my_old_index_name\nPUT my_old_index_name\/_alias\/my_alias\n/]
  73. [float]
  74. === Using date math with the rollover API
  75. It can be useful to use <<date-math-index-names,date math>> to name the
  76. rollover index according to the date that the index rolled over, e.g.
  77. `logstash-2016.02.03`. The rollover API supports date math, but requires the
  78. index name to end with a dash followed by a number, e.g.
  79. `logstash-2016.02.03-1` which is incremented every time the index is rolled
  80. over. For instance:
  81. [source,js]
  82. --------------------------------------------------
  83. # PUT /<logs-{now/d}-1> with URI encoding:
  84. PUT /%3Clogs-%7Bnow%2Fd%7D-1%3E <1>
  85. {
  86. "aliases": {
  87. "logs_write": {}
  88. }
  89. }
  90. PUT logs_write/log/1
  91. {
  92. "message": "a dummy log"
  93. }
  94. POST logs_write/_refresh
  95. # Wait for a day to pass
  96. POST /logs_write/_rollover <2>
  97. {
  98. "conditions": {
  99. "max_docs": "1"
  100. }
  101. }
  102. --------------------------------------------------
  103. // CONSOLE
  104. // TEST[s/now/2016.10.31||/]
  105. <1> Creates an index named with today's date (e.g.) `logs-2016.10.31-1`
  106. <2> Rolls over to a new index with today's date, e.g. `logs-2016.10.31-000002` if run immediately, or `logs-2016.11.01-000002` if run after 24 hours
  107. //////////////////////////
  108. [source,js]
  109. --------------------------------------------------
  110. GET _alias
  111. --------------------------------------------------
  112. // CONSOLE
  113. // TEST[continued]
  114. [source,js]
  115. --------------------------------------------------
  116. {
  117. "logs-2016.10.31-000002": {
  118. "aliases": {
  119. "logs_write": {}
  120. }
  121. },
  122. "logs-2016.10.31-1": {
  123. "aliases": {}
  124. }
  125. }
  126. --------------------------------------------------
  127. // TESTRESPONSE
  128. //////////////////////////
  129. These indices can then be referenced as described in the
  130. <<date-math-index-names,date math documentation>>. For example, to search
  131. over indices created in the last three days, you could do the following:
  132. [source,js]
  133. --------------------------------------------------
  134. # GET /<logs-{now/d}-*>,<logs-{now/d-1d}-*>,<logs-{now/d-2d}-*>/_search
  135. GET /%3Clogs-%7Bnow%2Fd%7D-*%3E%2C%3Clogs-%7Bnow%2Fd-1d%7D-*%3E%2C%3Clogs-%7Bnow%2Fd-2d%7D-*%3E/_search
  136. --------------------------------------------------
  137. // CONSOLE
  138. // TEST[continued]
  139. // TEST[s/now/2016.10.31||/]
  140. [float]
  141. === Defining the new index
  142. The settings, mappings, and aliases for the new index are taken from any
  143. matching <<indices-templates,index templates>>. Additionally, you can specify
  144. `settings`, `mappings`, and `aliases` in the body of the request, just like the
  145. <<indices-create-index,create index>> API. Values specified in the request
  146. override any values set in matching index templates. For example, the following
  147. `rollover` request overrides the `index.number_of_shards` setting:
  148. [source,js]
  149. --------------------------------------------------
  150. PUT /logs-000001
  151. {
  152. "aliases": {
  153. "logs_write": {}
  154. }
  155. }
  156. POST /logs_write/_rollover
  157. {
  158. "conditions" : {
  159. "max_age": "7d",
  160. "max_docs": 1000
  161. },
  162. "settings": {
  163. "index.number_of_shards": 2
  164. }
  165. }
  166. --------------------------------------------------
  167. // CONSOLE
  168. [float]
  169. === Dry run
  170. The rollover API supports `dry_run` mode, where request conditions can be
  171. checked without performing the actual rollover:
  172. [source,js]
  173. --------------------------------------------------
  174. PUT /logs-000001
  175. {
  176. "aliases": {
  177. "logs_write": {}
  178. }
  179. }
  180. POST /logs_write/_rollover?dry_run
  181. {
  182. "conditions" : {
  183. "max_age": "7d",
  184. "max_docs": 1000
  185. }
  186. }
  187. --------------------------------------------------
  188. // CONSOLE
  189. [float]
  190. === Wait For Active Shards
  191. Because the rollover operation creates a new index to rollover to, the
  192. <<create-index-wait-for-active-shards,`wait_for_active_shards`>> setting on
  193. index creation applies to the rollover action as well.