scripting.asciidoc 21 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592
  1. [[modules-scripting]]
  2. == Scripting
  3. The scripting module allows to use scripts in order to evaluate custom
  4. expressions. For example, scripts can be used to return "script fields"
  5. as part of a search request, or can be used to evaluate a custom score
  6. for a query and so on.
  7. The scripting module uses by default http://groovy.codehaus.org/[groovy]
  8. (previously http://mvel.codehaus.org/[mvel] in 1.3.x and earlier) as the
  9. scripting language with some extensions. Groovy is used since it is extremely
  10. fast and very simple to use.
  11. .Groovy dynamic scripting disabled by default from v1.4.3
  12. [IMPORTANT]
  13. ===================================================
  14. Elasticsearch versions 1.3.0-1.3.7 and 1.4.0-1.4.2 have a vulnerability in the
  15. Groovy scripting engine. The vulnerability allows an attacker to construct
  16. Groovy scripts that escape the sandbox and execute shell commands as the user
  17. running the Elasticsearch Java VM.
  18. If you are running a vulnerable version of Elasticsearch, you should either
  19. upgrade to at least v1.3.8 or v1.4.3, or disable dynamic Groovy scripts by
  20. adding this setting to the `config/elasticsearch.yml` file in all nodes in the
  21. cluster:
  22. [source,yaml]
  23. -----------------------------------
  24. script.groovy.sandbox.enabled: false
  25. -----------------------------------
  26. This will turn off the Groovy sandbox, thus preventing dynamic Groovy scripts
  27. from being accepted as part of a request or retrieved from the special
  28. `.scripts` index. You will still be able to use Groovy scripts stored in files
  29. in the `config/scripts/` directory on every node.
  30. To convert an inline script to a file, take this simple script
  31. as an example:
  32. [source,json]
  33. -----------------------------------
  34. GET /_search
  35. {
  36. "script_fields": {
  37. "my_field": {
  38. "script": "1 + my_var",
  39. "params": {
  40. "my_var": 2
  41. }
  42. }
  43. }
  44. }
  45. -----------------------------------
  46. Save the contents of the script as a file called `config/scripts/my_script.groovy`
  47. on every data node in the cluster:
  48. [source,js]
  49. -----------------------------------
  50. 1 + my_var
  51. -----------------------------------
  52. Now you can access the script by file name (without the extension):
  53. [source,json]
  54. -----------------------------------
  55. GET /_search
  56. {
  57. "script_fields": {
  58. "my_field": {
  59. "script_file": "my_test",
  60. "params": {
  61. "my_var": 2
  62. }
  63. }
  64. }
  65. }
  66. -----------------------------------
  67. ===================================================
  68. Additional `lang` plugins are provided to allow to execute scripts in
  69. different languages. Currently supported plugins are `lang-javascript`
  70. for JavaScript, `lang-mvel` for Mvel, and `lang-python` for Python.
  71. All places where a `script` parameter can be used, a `lang` parameter
  72. (on the same level) can be provided to define the language of the
  73. script. The `lang` options are `groovy`, `js`, `mvel`, `python`,
  74. `expression` and `native`.
  75. To increase security, Elasticsearch does not allow you to specify scripts for
  76. non-sandboxed languages with a request. Instead, scripts must be placed in the
  77. `scripts` directory inside the configuration directory (the directory where
  78. elasticsearch.yml is). Scripts placed into this directory will automatically be
  79. picked up and be available to be used. Once a script has been placed in this
  80. directory, it can be referenced by name. For example, a script called
  81. `calculate-score.groovy` can be referenced in a request like this:
  82. [source,sh]
  83. --------------------------------------------------
  84. $ tree config
  85. config
  86. ├── elasticsearch.yml
  87. ├── logging.yml
  88. └── scripts
  89. └── calculate-score.groovy
  90. --------------------------------------------------
  91. [source,sh]
  92. --------------------------------------------------
  93. $ cat config/scripts/calculate-score.groovy
  94. log(_score * 2) + my_modifier
  95. --------------------------------------------------
  96. [source,js]
  97. --------------------------------------------------
  98. curl -XPOST localhost:9200/_search -d '{
  99. "query": {
  100. "function_score": {
  101. "query": {
  102. "match": {
  103. "body": "foo"
  104. }
  105. },
  106. "functions": [
  107. {
  108. "script_score": {
  109. "script_file": "calculate-score",
  110. "params": {
  111. "my_modifier": 8
  112. }
  113. }
  114. }
  115. ]
  116. }
  117. }
  118. }'
  119. --------------------------------------------------
  120. The name of the script is derived from the hierarchy of directories it
  121. exists under, and the file name without the lang extension. For example,
  122. a script placed under `config/scripts/group1/group2/test.py` will be
  123. named `group1_group2_test`.
  124. [float]
  125. === Indexed Scripts
  126. If dynamic scripting is enabled, Elasticsearch allows you to store scripts
  127. in an internal index known as `.scripts` and reference them by id. There are
  128. REST endpoints to manage indexed scripts as follows:
  129. Requests to the scripts endpoint look like :
  130. [source,js]
  131. -----------------------------------
  132. /_scripts/{lang}/{id}
  133. -----------------------------------
  134. Where the `lang` part is the language the script is in and the `id` part is the id
  135. of the script. In the `.scripts` index the type of the document will be set to the `lang`.
  136. [source,js]
  137. -----------------------------------
  138. curl -XPOST localhost:9200/_scripts/groovy/indexedCalculateScore -d '{
  139. "script": "log(_score * 2) + my_modifier"
  140. }'
  141. -----------------------------------
  142. This will create a document with id: `indexedCalculateScore` and type: `groovy` in the
  143. `.scripts` index. The type of the document is the language used by the script.
  144. This script can be accessed at query time by appending `_id` to
  145. the script parameter and passing the script id. So `script` becomes `script_id`.:
  146. [source,js]
  147. --------------------------------------------------
  148. curl -XPOST localhost:9200/_search -d '{
  149. "query": {
  150. "function_score": {
  151. "query": {
  152. "match": {
  153. "body": "foo"
  154. }
  155. },
  156. "functions": [
  157. {
  158. "script_score": {
  159. "script_id": "indexedCalculateScore",
  160. "lang" : "groovy",
  161. "params": {
  162. "my_modifier": 8
  163. }
  164. }
  165. }
  166. ]
  167. }
  168. }
  169. }'
  170. --------------------------------------------------
  171. Note that you must have dynamic scripting enabled to use indexed scripts
  172. at query time.
  173. The script can be viewed by:
  174. [source,js]
  175. -----------------------------------
  176. curl -XGET localhost:9200/_scripts/groovy/indexedCalculateScore
  177. -----------------------------------
  178. This is rendered as:
  179. [source,js]
  180. -----------------------------------
  181. '{
  182. "script": "log(_score * 2) + my_modifier"
  183. }'
  184. -----------------------------------
  185. Indexed scripts can be deleted by:
  186. [source,js]
  187. -----------------------------------
  188. curl -XDELETE localhost:9200/_scripts/groovy/indexedCalculateScore
  189. -----------------------------------
  190. [float]
  191. === Enabling dynamic scripting
  192. We recommend running Elasticsearch behind an application or proxy, which
  193. protects Elasticsearch from the outside world. If users are allowed to run
  194. dynamic scripts (even in a search request), then they have the same access to
  195. your box as the user that Elasticsearch is running as. For this reason dynamic
  196. scripting is allowed only for sandboxed languages by default.
  197. First, you should not run Elasticsearch as the `root` user, as this would allow
  198. a script to access or do *anything* on your server, without limitations. Second,
  199. you should not expose Elasticsearch directly to users, but instead have a proxy
  200. application inbetween. If you *do* intend to expose Elasticsearch directly to
  201. your users, then you have to decide whether you trust them enough to run scripts
  202. on your box or not. If you do, you can enable dynamic scripting by adding the
  203. following setting to the `config/elasticsearch.yml` file on every node:
  204. [source,yaml]
  205. -----------------------------------
  206. script.disable_dynamic: false
  207. -----------------------------------
  208. While this still allows execution of named scripts provided in the config, or
  209. _native_ Java scripts registered through plugins, it also allows users to run
  210. arbitrary scripts via the API. Instead of sending the name of the file as the
  211. script, the body of the script can be sent instead.
  212. There are three possible configuration values for the `script.disable_dynamic`
  213. setting, the default value is `sandbox`:
  214. [cols="<,<",options="header",]
  215. |=======================================================================
  216. |Value |Description
  217. | `true` |all dynamic scripting is disabled, scripts must be placed in the `config/scripts` directory.
  218. | `false` |all dynamic scripting is enabled, scripts may be sent as strings in requests.
  219. | `sandbox` |scripts may be sent as strings for languages that are sandboxed.
  220. |=======================================================================
  221. [float]
  222. === Default Scripting Language
  223. The default scripting language (assuming no `lang` parameter is provided) is
  224. `groovy`. In order to change it, set the `script.default_lang` to the
  225. appropriate language.
  226. [float]
  227. === Groovy Sandboxing
  228. Elasticsearch sandboxes Groovy scripts that are compiled and executed in order
  229. to ensure they don't perform unwanted actions. There are a number of options
  230. that can be used for configuring this sandbox:
  231. `script.groovy.sandbox.receiver_whitelist`::
  232. Comma-separated list of string classes for objects that may have methods
  233. invoked.
  234. `script.groovy.sandbox.package_whitelist`::
  235. Comma-separated list of packages under which new objects may be constructed.
  236. `script.groovy.sandbox.class_whitelist`::
  237. Comma-separated list of classes that are allowed to be constructed.
  238. `script.groovy.sandbox.method_blacklist`::
  239. Comma-separated list of methods that are never allowed to be invoked,
  240. regardless of target object.
  241. `script.groovy.sandbox.enabled`::
  242. Flag to disable the sandbox (defaults to `false` added[v1.4.3] meaning the sandbox is
  243. disabled).
  244. When specifying whitelist or blacklist settings for the groovy sandbox, all
  245. options replace the current whitelist, they are not additive.
  246. [float]
  247. === Automatic Script Reloading
  248. The `config/scripts` directory is scanned periodically for changes.
  249. New and changed scripts are reloaded and deleted script are removed
  250. from preloaded scripts cache. The reload frequency can be specified
  251. using `watcher.interval` setting, which defaults to `60s`.
  252. To disable script reloading completely set `script.auto_reload_enabled`
  253. to `false`.
  254. [[native-java-scripts]]
  255. [float]
  256. === Native (Java) Scripts
  257. Even though `groovy` is pretty fast, this allows to register native Java based
  258. scripts for faster execution.
  259. In order to allow for scripts, the `NativeScriptFactory` needs to be
  260. implemented that constructs the script that will be executed. There are
  261. two main types, one that extends `AbstractExecutableScript` and one that
  262. extends `AbstractSearchScript` (probably the one most users will extend,
  263. with additional helper classes in `AbstractLongSearchScript`,
  264. `AbstractDoubleSearchScript`, and `AbstractFloatSearchScript`).
  265. Registering them can either be done by settings, for example:
  266. `script.native.my.type` set to `sample.MyNativeScriptFactory` will
  267. register a script named `my`. Another option is in a plugin, access
  268. `ScriptModule` and call `registerScript` on it.
  269. Executing the script is done by specifying the `lang` as `native`, and
  270. the name of the script as the `script`.
  271. Note, the scripts need to be in the classpath of elasticsearch. One
  272. simple way to do it is to create a directory under plugins (choose a
  273. descriptive name), and place the jar / classes files there. They will be
  274. automatically loaded.
  275. [float]
  276. === Lucene Expressions Scripts
  277. [WARNING]
  278. ========================
  279. This feature is *experimental* and subject to change in future versions.
  280. ========================
  281. Lucene's expressions module provides a mechanism to compile a
  282. `javascript` expression to bytecode. This allows very fast execution,
  283. as if you had written a `native` script. Expression scripts can be
  284. used in `script_score`, `script_fields`, sort scripts and numeric aggregation scripts.
  285. See the link:http://lucene.apache.org/core/4_9_0/expressions/index.html?org/apache/lucene/expressions/js/package-summary.html[expressions module documentation]
  286. for details on what operators and functions are available.
  287. Variables in `expression` scripts are available to access:
  288. * Single valued document fields, e.g. `doc['myfield'].value`
  289. * Parameters passed into the script, e.g. `mymodifier`
  290. * The current document's score, `_score` (only available when used in a `script_score`)
  291. There are a few limitations relative to other script languages:
  292. * Only numeric fields may be accessed
  293. * Stored fields are not available
  294. * If a field is sparse (only some documents contain a value), documents missing the field will have a value of `0`
  295. [float]
  296. === Score
  297. In all scripts that can be used in aggregations, the current
  298. document's score is accessible in `_score`.
  299. [float]
  300. === Computing scores based on terms in scripts
  301. see <<modules-advanced-scripting, advanced scripting documentation>>
  302. [float]
  303. === Document Fields
  304. Most scripting revolve around the use of specific document fields data.
  305. The `doc['field_name']` can be used to access specific field data within
  306. a document (the document in question is usually derived by the context
  307. the script is used). Document fields are very fast to access since they
  308. end up being loaded into memory (all the relevant field values/tokens
  309. are loaded to memory). Note, however, that the `doc[...]` notation only
  310. allows for simple valued fields (can’t return a json object from it)
  311. and makes sense only on non-analyzed or single term based fields.
  312. The following data can be extracted from a field:
  313. [cols="<,<",options="header",]
  314. |=======================================================================
  315. |Expression |Description
  316. |`doc['field_name'].value` |The native value of the field. For example,
  317. if its a short type, it will be short.
  318. |`doc['field_name'].values` |The native array values of the field. For
  319. example, if its a short type, it will be short[]. Remember, a field can
  320. have several values within a single doc. Returns an empty array if the
  321. field has no values.
  322. |`doc['field_name'].empty` |A boolean indicating if the field has no
  323. values within the doc.
  324. |`doc['field_name'].multiValued` |A boolean indicating that the field
  325. has several values within the corpus.
  326. |`doc['field_name'].lat` |The latitude of a geo point type.
  327. |`doc['field_name'].lon` |The longitude of a geo point type.
  328. |`doc['field_name'].lats` |The latitudes of a geo point type.
  329. |`doc['field_name'].lons` |The longitudes of a geo point type.
  330. |`doc['field_name'].distance(lat, lon)` |The `plane` distance (in meters)
  331. of this geo point field from the provided lat/lon.
  332. |`doc['field_name'].distanceWithDefault(lat, lon, default)` |The `plane` distance (in meters)
  333. of this geo point field from the provided lat/lon with a default value.
  334. |`doc['field_name'].distanceInMiles(lat, lon)` |The `plane` distance (in
  335. miles) of this geo point field from the provided lat/lon.
  336. |`doc['field_name'].distanceInMilesWithDefault(lat, lon, default)` |The `plane` distance (in
  337. miles) of this geo point field from the provided lat/lon with a default value.
  338. |`doc['field_name'].distanceInKm(lat, lon)` |The `plane` distance (in
  339. km) of this geo point field from the provided lat/lon.
  340. |`doc['field_name'].distanceInKmWithDefault(lat, lon, default)` |The `plane` distance (in
  341. km) of this geo point field from the provided lat/lon with a default value.
  342. |`doc['field_name'].arcDistance(lat, lon)` |The `arc` distance (in
  343. meters) of this geo point field from the provided lat/lon.
  344. |`doc['field_name'].arcDistanceWithDefault(lat, lon, default)` |The `arc` distance (in
  345. meters) of this geo point field from the provided lat/lon with a default value.
  346. |`doc['field_name'].arcDistanceInMiles(lat, lon)` |The `arc` distance (in
  347. miles) of this geo point field from the provided lat/lon.
  348. |`doc['field_name'].arcDistanceInMilesWithDefault(lat, lon, default)` |The `arc` distance (in
  349. miles) of this geo point field from the provided lat/lon with a default value.
  350. |`doc['field_name'].arcDistanceInKm(lat, lon)` |The `arc` distance (in
  351. km) of this geo point field from the provided lat/lon.
  352. |`doc['field_name'].arcDistanceInKmWithDefault(lat, lon, default)` |The `arc` distance (in
  353. km) of this geo point field from the provided lat/lon with a default value.
  354. |`doc['field_name'].factorDistance(lat, lon)` |The distance factor of this geo point field from the provided lat/lon.
  355. |`doc['field_name'].factorDistance(lat, lon, default)` |The distance factor of this geo point field from the provided lat/lon with a default value.
  356. |`doc['field_name'].geohashDistance(geohash)` |The `arc` distance (in meters)
  357. of this geo point field from the provided geohash.
  358. |`doc['field_name'].geohashDistanceInKm(geohash)` |The `arc` distance (in km)
  359. of this geo point field from the provided geohash.
  360. |`doc['field_name'].geohashDistanceInMiles(geohash)` |The `arc` distance (in
  361. miles) of this geo point field from the provided geohash.
  362. |=======================================================================
  363. [float]
  364. === Stored Fields
  365. Stored fields can also be accessed when executing a script. Note, they
  366. are much slower to access compared with document fields, as they are not
  367. loaded into memory. They can be simply accessed using
  368. `_fields['my_field_name'].value` or `_fields['my_field_name'].values`.
  369. [float]
  370. === Accessing the score of a document within a script
  371. When using scripting for calculating the score of a document (for instance, with
  372. the `function_score` query), you can access the score using the `_score`
  373. variable inside of a Groovy script.
  374. [float]
  375. === Source Field
  376. The source field can also be accessed when executing a script. The
  377. source field is loaded per doc, parsed, and then provided to the script
  378. for evaluation. The `_source` forms the context under which the source
  379. field can be accessed, for example `_source.obj2.obj1.field3`.
  380. Accessing `_source` is much slower compared to using `_doc`
  381. but the data is not loaded into memory. For a single field access `_fields` may be
  382. faster than using `_source` due to the extra overhead of potentially parsing large documents.
  383. However, `_source` may be faster if you access multiple fields or if the source has already been
  384. loaded for other purposes.
  385. [float]
  386. === Groovy Built In Functions
  387. There are several built in functions that can be used within scripts.
  388. They include:
  389. [cols="<,<",options="header",]
  390. |=======================================================================
  391. |Function |Description
  392. |`sin(a)` |Returns the trigonometric sine of an angle.
  393. |`cos(a)` |Returns the trigonometric cosine of an angle.
  394. |`tan(a)` |Returns the trigonometric tangent of an angle.
  395. |`asin(a)` |Returns the arc sine of a value.
  396. |`acos(a)` |Returns the arc cosine of a value.
  397. |`atan(a)` |Returns the arc tangent of a value.
  398. |`toRadians(angdeg)` |Converts an angle measured in degrees to an
  399. approximately equivalent angle measured in radians
  400. |`toDegrees(angrad)` |Converts an angle measured in radians to an
  401. approximately equivalent angle measured in degrees.
  402. |`exp(a)` |Returns Euler's number _e_ raised to the power of value.
  403. |`log(a)` |Returns the natural logarithm (base _e_) of a value.
  404. |`log10(a)` |Returns the base 10 logarithm of a value.
  405. |`sqrt(a)` |Returns the correctly rounded positive square root of a
  406. value.
  407. |`cbrt(a)` |Returns the cube root of a double value.
  408. |`IEEEremainder(f1, f2)` |Computes the remainder operation on two
  409. arguments as prescribed by the IEEE 754 standard.
  410. |`ceil(a)` |Returns the smallest (closest to negative infinity) value
  411. that is greater than or equal to the argument and is equal to a
  412. mathematical integer.
  413. |`floor(a)` |Returns the largest (closest to positive infinity) value
  414. that is less than or equal to the argument and is equal to a
  415. mathematical integer.
  416. |`rint(a)` |Returns the value that is closest in value to the argument
  417. and is equal to a mathematical integer.
  418. |`atan2(y, x)` |Returns the angle _theta_ from the conversion of
  419. rectangular coordinates (_x_, _y_) to polar coordinates (r,_theta_).
  420. |`pow(a, b)` |Returns the value of the first argument raised to the
  421. power of the second argument.
  422. |`round(a)` |Returns the closest _int_ to the argument.
  423. |`random()` |Returns a random _double_ value.
  424. |`abs(a)` |Returns the absolute value of a value.
  425. |`max(a, b)` |Returns the greater of two values.
  426. |`min(a, b)` |Returns the smaller of two values.
  427. |`ulp(d)` |Returns the size of an ulp of the argument.
  428. |`signum(d)` |Returns the signum function of the argument.
  429. |`sinh(x)` |Returns the hyperbolic sine of a value.
  430. |`cosh(x)` |Returns the hyperbolic cosine of a value.
  431. |`tanh(x)` |Returns the hyperbolic tangent of a value.
  432. |`hypot(x, y)` |Returns sqrt(_x2_ + _y2_) without intermediate overflow
  433. or underflow.
  434. |=======================================================================
  435. [float]
  436. === Arithmetic precision in MVEL
  437. When dividing two numbers using MVEL based scripts, the engine tries to
  438. be smart and adheres to the default behaviour of java. This means if you
  439. divide two integers (you might have configured the fields as integer in
  440. the mapping), the result will also be an integer. This means, if a
  441. calculation like `1/num` is happening in your scripts and `num` is an
  442. integer with the value of `8`, the result is `0` even though you were
  443. expecting it to be `0.125`. You may need to enforce precision by
  444. explicitly using a double like `1.0/num` in order to get the expected
  445. result.