ElasticSearch Connector - Source Code
<ApiConfig Name="ElasticSearch"
Slug="elasticsearch-connector"
Id="1e2e2142-9282-45d2-ac10-e0d5b61d1caa"
Version="3"
EngineVersion="14"
Desc="Read / write ElasticSearch data inside your app; perform many ElasticSearch operations without coding, just use easy to use high performance API Connector for ElasticSearch"
Logo="data:image/png;base64,iVBORw0KGgoAAAANSUhEUgAAAGQAAABjCAYAAABt56XsAAAJk2lDQ1BERUxMIFVQMzIxNlEgQ29sb3IgUHJvZmlsZSwgRDY1MDAAAHicnZZ3UFTJFof73js5AMMMQ4YhDTnDMIDkOATJUVRwyJkhipgQcQUURUQElAURCQom4ioioBhYFBRQMQyyCCjr4iqigvJgfVXuq31Vr+r9qrrPV6dP1znd/UcfAAiWVrbWdrAQAHHxKTxPB2uGf0AgA/sCoAEdCAAmoIRwkxNdvey9waps7VxcwD/0cRRAa/aB5to6Cd+rNMdIeQdw+2xuhVUe+Gf8f4gQGpbMXbXLqyOHm8hLAQDatcrs9JTENW5fZRpvtahVHljjiO/MX+Mt3/nDXzHenjYAwDgAcKSIv/GWvzE3MiR0NSVtNV7j33nXpLZWN8PHXV9Pl+XBsEmITeAx3HkJ4VGxYRoMW5ahjs7/OMT/q5SwjJQ1a5OQuJUXFRGZwlDhqjL0dHQNGbZhsbEMTjxX67/tW3uj7/Tj7n/4TrMA8FktGdv1w6cVAEDFZQAodT98CvYACEgB0NHPTeWlffeh1iY0IABBQAPiQAYoABWgCfSAETAFlsAOOAE34A0CwCbABZEgDvBAOsgCu0EuyAeHwFFQBipBDagHTeAiaANXwHVwE9wF98EIGAd8MAXegHnwESxBEISFyBAVEodkISVIHdKD2JA5ZAe5QJ5QABQMRUDxUCqUBe2B8qEiqAyqguqhC1AHdB26DQ1Bj6EJaBb6E/oCIzAJpsHSMBPWhtmwFewMe8Mb4Qg4Cc6Ec+CDcClcDZ+FW+Hr8F14BObDb+AFBCBEhI7IIZoIG7FB3JBAJBzhITuQPKQEqUaakE6kH3mA8JE55DMKg6KiGChNlCnKEeWD4qKSUDtQBagyVB2qFdWHeoCaQM2jvqHJaCm0OtoEzUH7oyPQ6ehcdAm6Ft2CvoEeQU+hP2IwGDpGGWOEccQEYKIx2zAFmBOYZkw3ZggziVnAYrHiWHWsGdYNG4JNweZij2PPYq9hh7FT2E84Ik4Wp4ezxwXi4nHZuBJcA64LN4ybxi3hhfBKeBO8Gz4UvxVfiK/Bd+Lv4afwSwQKQZlgRvAmRBN2E0oJTYQbhKeE90QiUZ5oTPQgRhF3EUuJ54m3iBPEzyRhkhrJhhRESiUdJJ0hdZMek96TyWQm2ZIcSE4hHyTXk3vJz8mfBKgCWgIcgVCBnQLlAq0CwwJvBfGCSoJWgpsEMwVLBC8J3hOcE8ILMYVshEKEdgiVC3UIjQktUKgUXYobJY5SQGmg3KbMCGOFmcJ2wqHCOcKnhHuFJ6kIVYFqQ+VS91BrqDeoUzQMTZnGoUXT8mnnaIO0eRFhEQMRX5EMkXKRqyJ8OkJn0jn0WHoh/SJ9lP5FVFrUSjRMdL9ok+iw6KKYpJilWJhYnliz2IjYF3GGuJ14jPhh8TbxZxIoCTUJD4l0iZMSNyTmJGmSppJcyTzJi5JPpGApNSlPqW1Sp6QGpBakZaQdpBOlj0v3Ss/J0GUsZaJlimW6ZGZlqbLmslGyxbLXZF8zRBhWjFhGKaOPMS8nJecolypXJTcotySvLO8jny3fLP9MgaDAVghXKFboUZhXlFV0VcxSbFR8ooRXYitFKh1T6ldaZCoz/Zj7mG3MGWUxZY5ypnKj8lMVsoqFSpJKtcpDVYwqWzVG9YTqfTVYzVAtUq1c7Z46rM5Sj1I/oT6kgdYw1ojXqNYY0yRpWmmmaTZqTmjRtVy0srXatN5qK2oHah/W7tf+pmOoE6tTozOuK6zrpJut26n7p56aHlevXO+hPlnfXn+nfrv+OwN1gzCDkwaPDKmGrob7DHsMv7KMWDxWE2vWSNEo2KjCaIxNY7uzC9i3jNHG1sY7ja8YfzZhmaSYXDT5w1TTNMa0wXRmnfK6sHU16ybN5M1CzKrM+OYM82Dzn835FnIWIRbVFi8tFSxDLWstp61UraKtzlq9tdax5lm3WC/amNhst+m2RWwdbPNsB+2E7Xzsyuye28vbR9g32s87GDpsc+h2RDs6Ox52HONIc7ices68k5HTdqc+Z5Kzl3OZ80sXNReeS6cr7OrkesT16Xql9fHr29yAG8ftiNszd2X3JPdfPDAe7h7lHq88dT2zPPu9qF6bvRq8Pnpbexd6j/uo+KT69PgK+gb51vsu+tn6Ffnx/bX9t/vfDZAIiApoD8QG+gbWBi5ssNtwdMNUkGFQbtDoRuWNGRtvb5LYFLvp6mbBzSGbLwWjg/2CG4KXQ9xCqkMWtnC2VGyZ59pwj3HfhFqGFofOhpmFFYVNh5uFF4XPRJhFHImYjbSILImci7KJKot6F+0YXRm9GOMWcyZmJdYvtjkOFxcc1xEvHB8T35cgk5CRMJSonpibyE8ySTqaNM9z5tUmQ8kbk9tTaKsf40CqSure1Ik087TytE/pvumXMigZ8RkDW9W27t86nWmfeXobaht3W0+WXNburIntVturdkA7tuzo2amwM2fn1C6HXXW7Cbtjdv+arZNdlP1hj9+ezhzpnF05k3sd9jbmCuTycsf2me6r/An1U9RPg/v19x/f/y0vNO9Ovk5+Sf5yAbfgzgHdA6UHVg6GHxwsZBWePIQ5FH9o9LDF4boiSlFm0eQR1yOtxYzivOIPRzcfvV1iUFJ5jHAs9Ri/1KW0/bji8UPHl8siy0bKrcubK6Qq9lcsngg9MXzS8mRTpXRlfuWXn6N+flTlUNVazawuOYU5lXbqVY1vTf9p9un6Wona/NqvZ+LP8Os86/rqjerrG6QaChvhxtTG2bNBZ++fsz3X3qTZVNVMb84/D86nnn99IfjC6EXniz2X2JeaLitdrmihtuS1Qq1bW+fbItv47QHtQx1OHT2dpp0tv2j9cuaK3JXyqyJXC7sIXTldK9cyry10J3bPXY+4PtmzuWe817/3YZ9H3+AN5xu3btrf7O236r92y+zWldsmtzvusO+03WXdbR0wHGj51fDXlkHWYOs9o3vt943vdw6tG+oathi+/sD2wc2HnId3R9aPDI36jD4aCxrjPwp9NPM49vG7J2lPlsZ3PUU/zXsm9KzkudTz6heqL5r5LP7VCduJgZdeL8cnuZNvfkv+bXkq5xX5Vcm07HT9jN7MlVn72fuvN7yeepP4Zmku93fK7xVvVd5e/sPyj4F5//mpd7x3K38WvBd/f+aDwYeeBfeF5x/jPi4t5n0S/1T3mf25/4vfl+ml9GXsculX1a+d35y/PV2JW1lJDtfX+6sVgEi2q63Ai5WV98zVXqIYgK+FKytLVSsrX6sBQMYB6E79F4bKmf4rzD3rAAAACXBIWXMAAC4jAAAuIwF4pT92AAAeJklEQVR4nN1dCXxU1bn/z5KZTBayL0BCIBAWQREUUbGISl3bamur9b1qq+Laaq1L7bP1ad1+tlVrLdpKte6te63WtbYqLlQQBNkhEAiB7PsyM5nlvu9/7szk3iHBmckkJO/TD7jL3OX8z/n2c65d0zT8P6ExwkcJLxKeLzxFOE/YJWwTthjO5UsHhXuF24X3CK8VXi78ofDu4XroaLIfrBsnkeYJny/8deGJMf6G4BAkV4iLQ9e5RLgDOjBPCb8u3J3cxz0wjWZAjhe+TvhU4ZQkXpcj7Wsh3ij8oPCTGCZgRiMgFcK3Cp8LvZf3T/4WaD6RRIrrRUBJx9d8MjYEO2umvHkR4Jggm6Xy79yBrjJT+CHhy4RvEf57Ut+kHxptgLBhbhcu2P+QBs29FlrnP4GuD6B5NwsoTbLbLRyErjbCJBLLYhUWaWXPh8U5A8hYCEvmybJrthy3Rl+cO18Rflz4Z8L1yX81nUYLIDnCDwh/b78jgQ5o7S9Da30SWs9nMhK6pKE5cOyhRnea1bn5xzJ6avWR1PkmtPo7BZAjYck9H5ass2X8jYn+wQ+EjxZeIvxxsl7OSKMBkEnCf4VuOfWR1isgPI1g4/2AZ2Oo8R3SudPiuLQlBJ4tBFpAQP0QWvcHQONvYc2/RsD5nn7dPpou/Ibw5aHnSioNJyCpoftJt4QHZhkyEIksUaJiqnGn1rMaWu2N0Lrek8aSS1pdSXpES9+I8m5FsOYSWNr+AsvYu2FJO9J4IofOk6G/H07SzRUNJSAToPsEX4HesJT78rbwC7cKVwqvEP638IZ+fl8OXYlWGHdqTQ8iWPe/Amt7EoHoh6j8hbWu96HtPAXW4tthyb/SeAbbjhYY3+fRZN12KAA5Qvhq6GbjgOaLELvcd6GPFtr9vxf+R+gYHboXYAQj6EFw33XQmqVDWmkppQ7Bo/dDvE+wB8G9V8Pi2QzruN8Y7015R1DqDc8+KEomIFnC0nVxBXRnK1bi250cYo6Im4VvEp4bOSPYjeCeJdDang3piAG19NAQ9YzoKK15KYKBZlhLHzHqKo76PwsvFN4y2FslC5Bp0GXqUf0d1Dqldzd2yd9ebsGS7oQlLx3WnP0U8JnCi4XT+37cK2BcFgIjPfr8YSSLur/W9lcEZWBYJzxqVPYUx4ISvirsHsxdkgHILOFXoVtDEdK8fvhWVKH3w0oEKpugdYhk8gf0gzYrLBlO2CbmIuXYcji+Mll8gIgYMLV6sPYmaYRnDjIYBlKgiHWXUqyLrz5aIHw9dD8pYRosIOOEX0IUGL5Pd8Hz9Cr4dzSpbYudJqlFAaFI7CsC5P+8Br7Ve+B9eS1Sz5kLxwliTKX0Od9ay1OixH8Xpyk7DCTPozXdD02cSEuOyTW6QfhF4c2JXnowgLDl/gCjSRrU4H5mFbwvrBErSESTY4DIBlUAAbLa1D+DdZ3oWboctikFsJXnh67lFjH36/DJg3jMoSA9NhncdyNsaeInOqeED2RCD7F8N9ErDwaQ/xL+RmRLEzAe+QSel9eJKS9ApOwXfhiYrBZYsl2w5hnEkq9GeK/uZ4xE4nP5a6Uz/QLWMvqHkU7zLegW5GeJXDbRt80Q/rlxh/f1DfD8jWDY4+/QgaDY+WNgGdNnymrimCHYqTtqI5XED9LaXxFj5R3RgaeE9zLyfJXw9xO5ZKKAnAHdslIUqGmF56lV4kfZEpIumog6W1mOLsbC+9xfyB+BkSetTMSH80NruFeMlMWhMIwiWoul0BNfcVGigJhkpPeltQiKklajI0GyTco37/AIICMbDZ1kBGvdjH99LKAsDO+lT8aE2UPxXi6RFmTk9ejwRrCpC77/7NJHR4LE39rKDE695pX/t41c/WEii/68rU8ZASGdhWECZLJwYXjDv34fgm3uxEeHiCtLplNs+qy+fb5aXalbEgd5WEkcRK3rXWmMZmnRvPBeKnamhuviuVQirUjZGDGhAtsaEriEgQQQa1EmrFl90RbNu10PHlqSmZkdQuJIFotQ61kphslp4b2UJExsDTkgWcaNYGOnSRnHS5pYWLbSHGX6Rsizvi/dOlpIE+Xe/ZEREBLjcW/Hc5lBC2nNExgMHooizmD4mu51GBUK3UgUr+7Po/ceEu9lEgGkzfQc4gSytCvR5mNYhTGtCLGnebeMHv0RIWkH324VqjeEeibEe5VEAKmGXmSm9IilIEN56QkRFXoGFXp23z5/PdBbPUosLAMxhexvEd3XagSEGp4v4o/1Mom89U7oimqcusCUAngZxWUA0WqNb6hQoQugxjC85q3UX2rUjRCLqnDRxBixpIwP7+SLhbOkMVGiIovllueqC8wthWNRBQI7mxFs7lZhd73KRsCxWQ6o8LVgENaSbB3MMHk2qBwILCMswhsLMbKgeY17aJXE1bPiBYSJGHrph4d3WHPTkf7zU8XC6EVgbxsC2xvg31KPwI4mBBs6xRTsVeF2C8EhSEZrStvfQx+VCt1IZunNkRGM5+exAkIngUVq1wiX9XeCJd0B+9RCxc4zZkkn96uwemBHow7Q9kYE97Wr7CFjV5YQMLZJeYaryLOzwG3UiasQ8bmtppIh1gv0xnOJWAChx8kitWPiubDFYYdtQo5ilXgSEBhmCVQ16wBtrVcjyFZiVOhNAuSuUQoIxUCqdDRTcR2ra5IKCEPIv0OUM9joDuDl3d14o6YHeWL2zst3Ym6eAxVZKch1DtCYMiKshZmKU+ZP1F9BRgvz65FX8u4Qhd6Mfko5Rz6xXNUmzWTPMe5NarSX6chfwSDQvQENj2/vxB+3dqC6y69UAi3ev1d3wyk6oijVhqkCyhF5ThwhIM3ITsFYl31AvW7Io+vECG/QM/JStrGQKHOLozw6918V72UGAoR1Vb827tje7sNPVzVjeb1Hpb1ddnMrU5fVidde0+PHu/vcynDiaJmcacfhuU41imblOFCaYYfDOgBCNoqvUTg66Ay6jhB/6l5EGSQXQ/dF/ii8OpZL9QcI4/j3GHd8IiBcsaIRe3sC+wERJpVlZh2Dre94e28QK5u8WNHoxcNbgTEpVpQJIIcKMEcKQHMEqEPk32F8LGPk1q7D9ZFirqcduSRgMFtoLf2zGLljo4/ShGRhNicUPQ29IuWAs7OiAaGrTzQjUb0VAsaFHzWgVRo31RafOcqGdhjklVtE3sa2Xqxr7cXTO7uQIseWHp2Hb0/KCP0gDda8yxGsuWwUWL6aKsSw5PxAfCmxeawZBzqZipKjhZOLqAoGLNKOBoRialx4Y2eHT0ZGkwJjQDETB/ESVgEhjDZ10p+2deIbE9LhCIFtyT5HVZ6jt3IER3sDygm0FN4Ea/EvTVah2+fHja+uxO7WLvxwwSE4eUaJ8Yd04f8ifBj0moT9fBQjICcJfye80SuNdYPojD2iE1xxjoxYiYbA5y1epXNOLw0pctsYcTYvRrD2+pEJiOZXcTbruPtgyb/CdKipy4PLX/gI/9i0R3W89yprcdr0Etx22hGYVpRtPJWTfhhR/SGiwiphQNjiN8KgUZ+u7ML7dZ4BdUayiFbaI9s6cEpJGsK4c8IMmpcCvn0jK8jIkI4tR0TUw7BknWU6tKOxAxc+uxwr9zQizaE/Mw2dVzdV49PqRvzm60fhO3PKjT+5FHrZ6TXGneG3nSN8QnhnizeAB7e0YxBp8piJompFgxcf17mxcGwoa2gvENl8AbT620YOIDTHxay1TnhCfCezj/zprgZc/Nxy7GzuQlpK3/Oyf7lku8XtxcXPf4jajh5cffws409/DL1A+4/hHeFfn234N14Rp2+X+BlDPTrCD+3TdF3yFQEkfEeKrUDzMmkIOrsH2XOnJZU2X8B4UuSsaboKXtuwG1e+9Ala3b1IHaAH28VhC8o73vTGZ+qcS4+dYTxMvf2J8BfqXOhxqsXho6I6lBduG0Z3gLrkPRkha8REpkOpyFEqo+Q8aA33CTrOgzRSQpaUmONqCoLdPNd02Seb8T+vfwZfUIyeL2kw6hSbnMPzK/KzcMLUiO3E8lO6Gcz9BviWrNqOFKdWiWW1sc0nqA6f3ck70SR+cHM7HjmuMOKXWMWKCVpcagoAeqsis5qGh8QACor3nXsprON/a5qtFQxquO3tNbjn/Q3K7+IIiIVsAoo3EMR1f/8U7155OnL7wkacxsDiw1cJyOnQ58opoo/Q6Yvf5xgMaaE/8kPp4IjcsufBOvYOoOBqaK3PifT6s14AoRIuDgyZs8K8hgBiKbpFzNqbTffp9vpw7Sv/wZOrK5FqHzgsNBBxJG1saMMDyzfg1tOOMB7iIgivExBWd0XkwVZx3IZz+RPpbPDLH9fNzMKNs3PQbz+wF8JScBVseRdBa38NWssyaN0rdKuH4iyZ4RZV7ZKqm7V5F5sO1YlSvvS5j/DOtr0RSyoRSrXb8Piq7VhyzHSUZEdiX5RUh/Oq0003dQ9fPW0gVBxx+5xcXDbDPCe80+9Dpj1KPFnTRa98V5zH76gZuJxvqHW9IxfqDAEzSOXPbJ+tQOkLy5jTTYe21Lfhwr8ux+f7mgcFBskmMrmu040X1u7ETxYdGtktfCavbApPdnFex6BuFxv5ZFS4ZPjeMy+3L3QSorXtrbhyw2qMS3VhSWk5TsovQopRTotnbMlcrFhzfy7A/ElGzt/0AgmKskQMAFHecE5TllTUFGh8tKMOS577ENXt3SazdjBkl3d/bWM1rl44UwCKvNui8LzxSNdKGQY0egUM5lGWHp2Pk8aZ54e+31SPKzauQUOvF1t7uvBBSyPmjMnG90sm4uuF4zEmxTxqLK45sJQ8BBTegGDLE6JrnpEb7AxN1IwxQEmzNv045WPAYZoMhpfWVuGqv61Ah+gOippkEY2mzfXt2N3ShfL8iHSoICA1MKRlcxzWmGb0J0oeGYET0+1YtqAAc/PNcz9ert2DazevQ3fQD6dhRKzpaMNnmz7HA7u247xxE3DO2Alq9JhIGtJafKtYBj8Sq+x5AYcGwDr92IAGQMiszTpbxNTD0i3Ns7iXLt+Im99arUTrl5m18RLN4A5vLzbVtRkBySYgK6FHedUTl2WkxLbGQgJE03Z2tgPLjivAlDHmnr5s9w7csn2DiralWMwv7wiBU+XuwS+3b8Ky6p34ZtF4nC+jZnpG1HokXEwm/0pp2wuhdfxDxNkyNVUAmifKAKBZ2yvnXiUK/NemiUF+MU1vfmM1HvhoI1IEiKFyAQJiPVW1dJpelYD8E/okf9XlmESKZzZarNTj13B8USr+cGwBitMMEzvloe7esRn3Vm2Dnc7TAexIHrfbbGj29eKh6h14prYap4h+ubBkEo7OiZpfIn4Dlb8l+9v6agwEpvOtUBE3X9smI+pOMW1vNP2sw9OLq19agWdF4TLsMdgy2S8jBiSNT80nEzMFtdCXslCAFLvsqPcE+jdB4yQONreAcdaENNw/Px9jHH1oe4MB/HzLF3i0Zpf4PbaYjQmC5pLzPfL75+tq8GpDLRZk5ylgFhcUibgzynoLLBknKGaJkdb8iALGWnSzOH0XmK5b09aNS579EO/tqB20JRUr+QIB0zbvygwWJygqQHKcViyUnvxMVdegw+4EgzmPiysycecRuZGcB6nD58OPN63B3+r3qcZN5E5W+ZVLGp/3eU+U//vCszOzcIGIsjNFpGWnmJU618KylPxeLekUvfTS+n0tyqzdKObtcIFBcjlMolsL31lsRpwT3nve5Ay8uLsbRqc5XlIOn4ij62dm48bDsk1Dv87jxmUbPhMLqglptsFbLrx02AhY19mOn2xei6ViAJwrBsB3xQAocUUVTUSB8e9t+3Apo7HiG7iGI8QdIj538RiTcRIMAyLCVVlbKr01vyAVJ4514c29PQmNElolbJ675uZiyTTzy1d2d2LJF6tUwyUDjGgKGwC7BfQ7Kjfj0T071Wg5f/xEzMzM2u/8l9dV4fIXP4bbF4AziWZtLETfamq+6Zm8YUBYr7tM+DZu0Kj42aHZ+KTBoyyjeDChw5dup8OXh29NNC+HsbqtBZes/wy7PN1KTA0lhQ2AFhGND4tV9td91VicV4QfTazAnKy+2qlesag6xcdwJcnhi5UC0k4FGamYUWzKJDYZn4ITFBm8UT7JrFwHbpiVhV+saRWHyBKT6KLDVyAO34PH5GPRWLOf8G5THX64YY2ykFKtw9cTwwaAVwvihfoarO1sw7vzFyEnpF/Onj0Jj63cho+q6od1hDBkf2RJPgozTe20wQgISwaZ641URFw2PQtb2314YkeX9PoDQ0KHrzxDd/gOzzM7fC9I77xuyzq4mTeIMVSdbKIBkGGzY0dPN57YU4VryvVp9vQzrl90KFbsahiUzoyb5GbnHF4evfft6HH6LPTY/EXcoOi6W0SPV3r+c1XdKoPY3wPTrJ0jI4pglEc5fH/YXSnO3Eb1silDbdTHQFT+j9ZU4bzxZShy6pWTJ00bj8UV4/DWtr1JDY8MRBSThxbn4FRzRQrXBX6tP8HJpDsTVmrSNfMiDxydr8pEWUKqGtbgudLhO7HYhYeOleHn6nsZpizvqtyE+8XaoaebmGGbfKII2yMK/0/iWP6iYqbaxzDGdSccpvwPNT1viB+VCa5rF81CutPUeV8TruoPEPrynIzD1d3UgmQE4FaxmOblp+LOL1qxRcQYvXl/UGRwWTrum5+HTIN77xFn52ciop7Yuzsuh2+4iKPkSXk2+isTXLrhsaC8CF+bUYoX1+8eUtO3x+fHmYdMwLcPNwUxWSHPOtQBa3s5ZY0r/XCVuJPDO88Qb3uBOI1PVXbiqR2dOEEU9+10+Awjpk2U9tUb1yjvOVGHb6iJo6Sx14uHRJzePX12ZP+1JxyKt7buVQrXOgTDhFP/puRl4p4z5xtD7qTHEFo96EC2Hhd2ZPERTeFrwudmiyd/1cwsXDQtU/wIq2l476PDt34VPmxtHhIfI5nklGd/rnYPLiqZhKmhAOUcsXq+M3siHv7P1lBQ0aqSSQeKr8VK1Bv56an487kLUZpjyv9wzub/hje+zPhmIRdrURnvYqFwZDHjdLvZWtra1YElAsYG+Xukg0Gi1dUmPgpD+ktn9eW27zpjHk6qGI9V1Y1YXdOEyuYONHV7I6MmDFI8ENHpLM1Kw2PnLcRREwuNhxhZZMFcZDmMWL0hRoS5lCvDK1zRmSm1SKBoZVszLhWHj8rSNYw+xmCJ+u3v9ftwUekkzM3ScyHZaU6cLfKdTAuGxW2b6lqxak+jgNSEzQ1tss8tliUrQC26wcLJSP2MItYK9IqYOr68GA+cfQymFZqcQNpHLJT7l3FnPO4pp5fymxosFuYKnD/gzi6/D1eJzqj29Ayrw5cMYhN2BvwyujsjgESfMFZ6NpmmMamtx4vtjR1q9HAUfVHbgurWbuXta/IfdYMq/hMRNV5+x4LrK46bER0JYNqHVSbLom+ZSLyA8eLI09d6PYqdowwMErsoxasxyaWpFTo10Y39O7AcQfPKChRfvmAGPGI17Wruwrp9zVgpAH22p0npi7NmleG/j5xirCoJEz8YwxXnnuzv+okAwpaPLBnRIGB4h8gqGWqir1TocKLMEA1u6t6Od3f+CoXp0zAu81AUpE9Fdup4EU39r6SdKj1/enG24nPnTlYxqgAjEv07mMzO/kh41UDPlAggDL5EonMtYub6tSCco3DmLFOoZeKH5BjyJo09ldjXuRZ1XRvwRf3LcNjSkOkoEmAqUJwxE0UZhyDXVSYe/X6fslCkrLL9pQUTgJw8uxRf8qWeRABhoCoSEfOKEzhaPytGQKZnZIp46hvdTd2VMtrtkRER0Pxo9VSj2V2FLU1vS2M7kZ6ShzzXJAHoEBRnzkRe2mRkOArQj+21FfpHYCie9sXyTIkAQuE6+uTTADQrw5wjaXLvkJfr0x9sZAsn6ERqvTR09TaKEq/DzraPxUexy2jJErFWgpIxczC/5CIBMxJc5QcF7o7neRIBxPT9oJSDFL0dLPEFGEKZYVDovYFutHtqBIADiV+auDZV9xU+y+vvRG3XehF16zApZ4HonsPCJzNQy4WVY15eIxFAaP5GSiWYt7aPUoWeK88+Ma3PCuqQXt/taxnQwhqIeL5N3DK/5kF91xYjIFz1m55gzMv8JQIIvXdmGJWlVehIVSYv8+ejCRbqj9JUF/IdfbmbFvcu8R88InISn5Ld4TWpCspDTgQZUkDoh+yFPpMUxamp0tNSUOf1JiXmM1xEQKalZ5qeuVFM3jgX74kiC3xB09cqONT2T+QfgBJNJNN6UKs9UmRNcmWgxuMZVYCQZkUVPTT1mBV6/MT6g/1GV1wXTBSQNeF/EIJ5WbmqJmo0EXM8RoXuC3rQ5tnzJQr9yynTWWTcpO3QOcCp/VKigDB2z6SK6g4n5BXigd3bhzcnPQiiQs+yO1Ce3hcG7/I2oLu3KW6FbiSax4Xppg/K0QmM6yOUiQLCL6zxoyUqu8Oymoq0DGzt6dyvUHokEl3Z8aL7ihx94ZBW924xe3vE8UtsDmNQC2CMsxhF6aYZtqwKrY3nOokC4oP+cUUFCDODZxWNxx07Ng/L3PbBEhV6RVqmyYdiyERT9kpigAS0XkzNPRFOe6Zx90cYghXlBiJ6ofzmknoDlm0u27MT7X7fiFfuLGSYlWmORTX1cNAn9twcHYx3zS7+dvShF+K91mAA4WwYrk56IjdKXWlqMs3vdm0f8RlDdpiZhpBJIOhTIsuagEJnuF4TQBaUXh6t0BnZXR7v9QYDCA12fgzyxPCOK8um4JX6vSo/MlK996A0YKbdjslGhc7YlHC8Cp1gBIJezBv3fRxSeEb04Tugi/a4aLAFra9D/3yqWvyDhWc/K5+OH21aI4CMzFFC/VEsynyss6+Es927F25fqx4UjLEfBTSf8lmOLlmCo0uXRB9mVjWhL38OFhD2AFZM8AsAqntRl7zX0oDna2tGnOiiWU5ALplQrvLpYSrKmKEadV3di3D721UEl/5IdDhd04KiL/xynSDy06bg2NLLMDl3YdRdwJUNrkGCEwOTUfL9LvTl69R0JGYO75p2mMpTr+9qH1F5dncggAvGl6mZVkZy2jKkcS/FjPxTsLHhdVS1faJiUnQWCQKJ4XenPQMFAsTUvK9iWv5iOGz7pWdpGbAQJGEvOVk1+Jyox64ykRsM2D186JE49/MVqPG4TTNqDxb1CBiLxYFlZ7GY9RvLR1Q75LjKcFzZlTJaLka7Z6+AUgtvoEsp+zR7LrJSx0crbiNRifMrk9sH85zJAoTRTK58zfpU5b2zcOCJw47CBes+xV5VBHHwQCEYi3LzsUw6SYbd9MpMq74sfB/0r1wroi7JSytXHAPRz+B6VxTd7YN91mTOUmExHUfKb8M7DhcP/i9zjsGl61dhs4iwoZ6kE01qwmnAj68VjsPvZ8415c6h10Pxq9Q9wsdDL2tizdms6OsMQAyLvAkdzBXJeuZkTxu6X5hrpf40vIMR1RfnLsD1m9fizcY6NT9kOBxHn8h+Vkj9eGIFbppySHSZEj+FQ/HSE9pm4/K76PwM91eE+ZXIedBzPnS9ObyZmOPHfRnp/gC6IbM12c89FPO4OOmHXTGyliBXXXhi9nz8cXelmp7ASpWhqoqnFcWypKniZ9xSMRNnFI6LPmWt8DfRf9KIyYx3Qkyis0LNTTQJCGuq4vYt4qGhAISS4ifQs4rMJ6t2Z9zoqklTsbigGPfu3II3ZLTQ6qFuSUZNFzOWvQJEgcOB740rww9lZBizgSFiz+Y3fGOqABHqCvGw0VDOdPwl9MpuirFIpSNzEI+Isv+0tRmP1VThX831aOrt1QuZLXqNbCzwhH0K1oTx/AmpaWq2Led8lKf1u6jxo9A7Slz5ieGmoZ56ylpgLu7Iz12YPKj5OXmKd/d0459NdXi3qR4bxG9pFHDY0xVZzI4zg4IEgtNRWNRdIiDMFcPhVBl1x+cWItfRby6cleVctPiRIXi/pNNwzAVmEJKTfrhoMJW9yZAvS0vHkgmTFTf2erCjuwvbujtR7e5RSzT1iJXEVUudFquKQRU7XZgkv6lIz5SRkL7/Imd9RFSfF+YafZVD+H5JpeGanE2FSPPwRehfXuB3SfKjTypwpCrebyGZ+IhJDU6f4Eqf//qSc0ccDffaq/zkHnModMjOg/49Kya5kuE1UlEzafa48MdJuN5BoYO1bDS/PMMFhOlEclVtrjt/HPT1H7k4LsvRB/IiKYroHdOK2wU9ZMGRQBCah/Khh4MO9jretOlXhpjEqB8/DX4sdKD4ZWoCRHDoAxBIRlM/hQ4A9VNcKdKRTv8HxmS8fy7cs9AAAAAASUVORK5CYII="
>
<VersionHistory>
<Change Date="2023-11-01" Type="New">Added support for password-less windows authentication (Use only if server supports it)</Change>
<Change Date="2023-09-10" Type="New">Added support for Alias (List/Read/Write)</Change>
<Change Date="2023-08-10" Type="New">Added IgnoreSSLCertificateErrors Property to support self-signed certificates (Ignore not trusted error)</Change>
<Change Date="2023-08-10" Type="New">Added two new endpoints (create_index, delete_index)</Change>
<Change Date="2023-08-10" Type="Fix">Fixed pagination issue</Change>
<Change Date="2021-12-08">Initial version</Change>
</VersionHistory>
<ServiceUrls>
<ServiceUrl Name="Default" Url="http://localhost:9200" />
</ServiceUrls>
<Auths>
<Auth Name="HTTP" Type="HTTP" Label="Basic Authentication (UserId/Password)" ConnStr="UserName=[$UserName$];Password=[$Password$]" TestEndPoint="list_indexes">
<Notes>
<![CDATA[]]>
</Notes>
<Params>
<Param Name="UserName" />
<Param Name="Password" Secret="true" />
<Param Name="IgnoreSSLCertificateErrors" Options=";True;False" />
</Params>
</Auth>
<Auth Name="WinAuth" Type="HTTP" Label="Windows Authentication (No Password)" ConnStr="CredentialType=Windows;" TestEndPoint="list_indexes" >
<Params>
<Param Name="IgnoreSSLCertificateErrors" Options=";True;False" />
</Params>
</Auth>
</Auths>
<Template>
<EndPoint>
<Params>
<Param Name="IgnoreSSLCertificateErrors" Type="Property" Options=";True;False" Desc="Set this option to True if you are getting Certificate Not Trusted error and you like to continue regardless (Only do it if you trust the remote server). This usually happens when Self-Signed certificate is used on ElasticSearch Instance and you did not trust that certificate on this machine" />
</Params>
</EndPoint>
<EndPoint Name="SearchWithPagination"
Url="/[$Index$]/_search" Method="POST" ContentType="application/json" Filter="$.hits.hits[*]"
Body="{ "from": {$$page_num$$}, "size": [$PagingIncrementBy$], "query": [$Query$] }"
IncludeParentColumns="True"
>
<Params>
<Param Name="Index" Type="Placeholder" Required="True" OptionsEndPoint="list_indexes" OptionsEndPointValueColumn="Name" />
<Param Name="Query" Label="Enter Query (JSON Format)"
Value="{"match_all": { } }"
HelpLink="https://www.elastic.co/guide/en/elasticsearch/reference/6.8/query-dsl-match-query.html"
Options="All Records={"match_all": { } };Record where comment or name contains TV word={"query_string": {"query": "comment:TV OR name:TV"} };Record with comment field (attribute exists)={"query_string": {"query": "_exists_:comment"} }"
/>
<Param Name="PagingMode" Value="ByPostData" Type="Property" />
<Param Name="PagingByUrlAttributeName" Value="{$$page_num$$}" Type="Property" />
<Param Name="PagingIncrementBy" Type="Property" Label="Records per page" Value="1000"/>
</Params>
<OutputColumns>
<Column Name="_id" Label="_id" DataType="DT_WSTR" />
<Column Name="_score" Label="_score" DataType="DT_R8"/>
<Column Name="_source.[$parent.Pivot_Path$]"
Label="[$parent.Pivot_Path$]"
Expand="True"
DataEndPoint="get_index_metadata"
DataEndPointParameters="Index=[$Index$]"
ColumnInfoMap="Name=Pivot_Path;"
DataTypeMap="DT_WSTR=text;DT_I8=long"
/>
</OutputColumns>
</EndPoint>
<EndPoint Name="ScrollWithPagination"
Url="/[$tag$]" Method="POST" ContentType="application/json" Filter="$.hits.hits[*]"
Body="[$tag$]"
Body1="{ "from": {$$page_num$$}, "size": [$PagingIncrementBy$], "query": { "query_string": {"query": "[$Query$]"} } }"
IncludeParentColumns="True"
>
<Params>
<Param Name="Index" Label="Index" Type="Placeholder" Required="True" OptionsEndPoint="list_indexes" OptionsEndPointValueColumn="Name" />
<Param Name="Alias" Label="Alias" Type="Placeholder" OptionsEndPoint="list_aliases" OptionsEndPointValueColumn="Name" />
<Param Name="Query" Label="Enter Query (JSON Format)"
Value="{"match_all": { } }"
HelpLink="https://www.elastic.co/guide/en/elasticsearch/reference/6.8/query-dsl-match-query.html"
Options="All Records={"match_all": { } };Record where comment or name contains TV word={"query_string": {"query": "comment:TV OR name:TV"} };Record with comment field (attribute exists)={"query_string": {"query": "_exists_:comment"} }"
/>
<Param Name="CursorTimeout" Value="10" Options="1;2;5;10;60;180;" Hidden="True" Label="CursorTimeout (Minutes)" Desc="Enter this value carefully. Do not enter very long timeout else it will hold cursor longer on server memory space" />
<Param Name="PageSize" Value="1000" Hidden="True" Label="How many Record to fetch per request" Desc="Do not enter very large number or too small number to avoid performance issues." />
<Param Name="NextUrlAttributeOrExpr" Type="Property" Value="$._scroll_id" />
<Param Name="StopIndicatorAttributeOrExpr" Type="Property" Value="$.hits.hits[0]._id" />
<Param Name="NextUrlEndIndicator" Type="Property" Value="regex=^$" Desc="Stop pagination when blank value detected for _id."/>
<Param Name="EnablePageTokenForBody" Type="Property" Value="True" />
<Param Name="HasDifferentNextPageInfo" Type="Property" Value="True" />
<Param Name="PagePlaceholders" Type="Property" Value="{}" ValueTemplate="url=<<[$Alias$]|~|[$Index$]|~|$1,FUN_IF_NULL_OR_EMPTY>>/_search?scroll=[$CursorTimeout$]m|_search/scroll" />
<Param Name="FirstPageBodyPart" Type="Property" Value="{}" ValueTemplate="{ "size": [$PageSize$], "query": [$Query$] }" />
<Param Name="NextPageBodyPart" Type="Property" Value="{}" ValueTemplate="{ "scroll" : "[$CursorTimeout$]m", "scroll_id": "[$pagetoken$]" }" />
</Params>
<OutputColumns>
<Column Name="_id" Label="_id" DataType="DT_WSTR" />
<Column Name="_score" Label="_score" DataType="DT_R8"/>
<Column Name="_source.[$parent.Pivot_Path$]"
Label="[$parent.Pivot_Path$]"
Expand="True"
DataEndPoint="get_index_metadata"
DataEndPointParameters="Index=[$Index$];Alias=[$Alias$]"
ColumnInfoMap="Name=Pivot_Path;"
DataTypeMap="DT_WSTR=text;DT_I8=long"
/>
</OutputColumns>
</EndPoint>
</Template>
<EndPoints>
<!--=====================================
=========== CREATE INDEX ============
=====================================-->
<EndPoint Name="create_index" Label="Create Index" Desc="Create a new index"
Url="/[$Name$]" Method="PUT" ContentType="application/json"
>
<Params>
<Param Name="Name" Label="New Index Name" Required="True"/>
<Param Name="ContineOnErrorForStatusCode" Type="Property" Value="True" />
<Param Name="ErrorStatusCodeToMatchRegex" Type="Property" Value="400" />
<Param Name="ConsumeResponseOnError" Type="Property" Value="True" />
</Params>
<OutputColumns>
<Column Name="acknowledged" Label="Acknowledged" DataType="DT_BOOL" />
<Column Name="acknowledged" Label="Name" DataType="DT_WSTR" Length="255" ValueTemplate="[$Name$]"/>
<Column Name="shards_acknowledged" Label="ShardsAcknowledged" DataType="DT_BOOL" />
<Column Name="index" Label="Index" DataType="DT_WSTR" Length="150"/>
</OutputColumns>
</EndPoint>
<!--=====================================
=========== DELETE INDEX ============
=====================================-->
<EndPoint Name="delete_index" Label="Delete Index" Desc="Delete an exising index"
Url="/[$Name$]" Method="DELETE" ContentType="application/json"
>
<Params>
<Param Name="Name" Label="Index to delete" Required="True" OptionsEndPoint="list_indexes" OptionsEndPointValueColumn="Name" />
<Param Name="ContineOn404Error" Type="Property" Value="True" />
<Param Name="ConsumeResponseOnError" Type="Property" Value="True" />
</Params>
<OutputColumns>
<Column Name="acknowledged" Label="Acknowledged" DataType="DT_BOOL" />
<Column Name="acknowledged" Label="Name" DataType="DT_WSTR" Length="255" ValueTemplate="[$Name$]"/>
<Column Name="status" Label="ErrorStatus" DataType="DT_I4" />
<Column Name="error.reason" Label="ErrorReason" DataType="DT_WSTR" Length="1000"/>
<Column Name="error.type" Label="ErrorType" DataType="DT_WSTR" Length="255"/>
<Column Name="error.resource.id" Label="ErrorId" DataType="DT_WSTR" Length="255"/>
<Column Name="error.index" Label="ErrorIndex" DataType="DT_WSTR" Length="255"/>
</OutputColumns>
</EndPoint>
<!--=====================================
=========== LIST INDEXES ============
=====================================-->
<EndPoint Name="list_indexes" Label="List indexes" Desc="Lists indexes"
Url="/_cat/indices?format=json&pretty" Method="GET" ContentType="application/json" Filter="$"
>
<OutputColumns>
<Column Name="index" Label="Name" DataType="DT_WSTR" Length="4000"/>
<Column Name="uuid" Label="Uuid" DataType="DT_WSTR" Length="50"/>
<Column Name="status" Label="Status" DataType="DT_WSTR" Length="50"/>
<Column Name="health" Label="Health" DataType="DT_WSTR" Length="50"/>
<Column Name="pri" Label="Pri" DataType="DT_I4"/>
<Column Name="pri" Label="Rep" DataType="DT_I4"/>
<Column Name="docs.count" Label="DocsCount" DataType="DT_I4"/>
<Column Name="docs.deleted" Label="DocsDeleted" DataType="DT_I4"/>
<Column Name="store.size" Label="StoreSize" DataType="DT_WSTR" Length="50"/>
<Column Name="pri.store.size" Label="PriStoreSize" DataType="DT_WSTR" Length="50"/>
</OutputColumns>
</EndPoint>
<!--=====================================
=========== LIST ALIASES ============
=====================================-->
<EndPoint Name="list_aliases" Label="List aliases" Desc="Lists aliases"
IncludeParentColumns="True" Url="/_aliases?format=json&pretty" Method="GET" Filter="$..aliases"
>
<Params>
<Param Name="EnableCustomReplace" Type="Property" Value="True" />
<Param Name="SearchFor" Type="Property" Value=""(\w+(?<!aliases))"\s*:\s*\{\s*\}--regex" />
<Param Name="ReplaceWith" Type="Property" Value=""$1": {fake:1}" />
<Param Name="EnablePivot" Type="Property" Value="True" />
<Param Name="IncludePivotPath" Type="Property" Value="True" />
<Param Name="EnablePivotPathSearchReplace" Type="Property" Value="True" />
<Param Name="PivotPathSearchFor" Type="Property" Value="(.*?).aliases.(.*)--regex" />
<Param Name="PivotPathReplaceWith" Type="Property" Value="$1" />
</Params>
<OutputColumns>
<Column Name="Pivot_Name" Label="Name" DataType="DT_WSTR" Length="500"/>
<Column Name="Pivot_Path" Label="Index" DataType="DT_WSTR" Length="500"/>
</OutputColumns>
</EndPoint>
<!--=====================================
======== GET INDEX METADATA =========
=====================================-->
<EndPoint Name="get_index_metadata" Label="Get index metadata" Desc="Gets index metadata"
Url="/<<[$Alias$]|~|[$Index$]|~|$1,FUN_IF_NULL_OR_EMPTY>>/_mappings" Method="GET" ContentType="application/json" IncludeParentColumns="True"
Filter="$..properties" >
<Params>
<Param Name="Index" Type="Placeholder" Required="True" OptionsEndPoint="list_indexes" OptionsEndPointValueColumn="Name" Desc="Enter index name. If you set alias then select underlying alias Index here." />
<Param Name="Alias" Type="Placeholder" OptionsEndPoint="list_aliases" OptionsEndPointValueColumn="Name" />
<Param Name="EnablePivot" Type="Property" Value="True" />
<Param Name="IncludePivotPath" Type="Property" Value="True" />
<Param Name="EnablePivotPathSearchReplace" Type="Property" Value="True" />
<Param Name="PivotPathSearchFor" Type="Property" Value="-" ValueTemplate="^[$Alias$].mappings.|^[$Index$].mappings.|properties.--regex" />
<Param Name="PivotPathReplaceWith" Type="Property" Value="" />
</Params>
<OutputColumns>
<Column Name="Pivot_Path" Label="Path" DataType="DT_WSTR" Length="4000"/>
<Column Name="Pivot_Name" Label="Name" DataType="DT_WSTR" Length="4000"/>
<Column Name="Pivot_Value.type" Label="Type" DataType="DT_WSTR" Length="4000"/>
<Column Name="Pivot_Value.fields.keyword.ignore_above" Label="Length" DataType="DT_I4" />
</OutputColumns>
</EndPoint>
<!--=====================================
========== GET DOCUMENTS ============
=====================================-->
<EndPoint Name="get_documents" Label="Get documents from Index or Alias" Desc="Gets documents from Index or Alias"
Template="ScrollWithPagination" HelpLink="https://www.elastic.co/guide/en/elasticsearch/reference/6.8/query-dsl-match-query.html"
>
</EndPoint>
<!--=====================================
========== GET DOCUMENT BY ID ============
=====================================-->
<EndPoint Name="get_document" Label="Get document by ID from Index or Alias"
Url="/<<[$Alias$]|~|[$Index$]|~|$1,FUN_IF_NULL_OR_EMPTY>>/_doc/[$Id$]" Method="GET" ContentType="application/json" Filter=""
Body="{ "query": [$Query$] }"
IncludeParentColumns="True"
>
<Params>
<Param Name="Index" Type="Placeholder" Desc="Enter index name. If you set alias then select underlying alias Index here." Required="True" OptionsEndPoint="list_indexes" OptionsEndPointValueColumn="Name" />
<Param Name="Alias" Type="Placeholder" OptionsEndPoint="list_aliases" OptionsEndPointValueColumn="Name" />
<Param Name="Id" Label="Enter Document ID"
Value="" Required="True" IsKey="True" ReadAs="_id"
/>
</Params>
<OutputColumns>
<Column Name="_id" Label="_id" DataType="DT_WSTR" />
<Column Name="_score" Label="_score" DataType="DT_R8"/>
<Column Name="_source.[$parent.Pivot_Path$]"
Label="[$parent.Pivot_Path$]"
Expand="True"
DataEndPoint="get_index_metadata"
DataEndPointParameters="Index=[$Index$]"
ColumnInfoMap="Name=Pivot_Path;"
DataTypeMap="DT_WSTR=text;DT_I8=long"
/>
</OutputColumns>
</EndPoint>
<!--=====================================
============== SEARCH ===============
=====================================-->
<EndPoint Name="search" Label="Search / Query documents" Desc="Gets documents (Using JSON Query Language)"
Template="ScrollWithPagination" HelpLink="https://www.elastic.co/guide/en/elasticsearch/reference/6.8/query-dsl-match-query.html"
>
</EndPoint>
<!--=====================================
========== COUNT DOCUMENTS ============
=====================================-->
<EndPoint Name="count" Label="Count documents"
Url="/[$Index$]/_count" Method="POST" ContentType="application/json"
Body="{ "query": [$Query$] }"
IncludeParentColumns="True"
>
<Params>
<Param Name="Index" MultiSelect="True" MultiSelectSeparator="," Label="Index or Alias Name (choose one --OR-- enter * --OR-- comma seperated names)"
Desc="You can enter index name(s) for which you like to perform document count. Enter * (asterisk) to perform search across all indices or comma seperate list (i.e. myidx1,myidx2) or select one from the populated list."
Type="Placeholder" Required="True" OptionsEndPoint="list_indexes" OptionsEndPointValueColumn="Name" />
<Param Name="Query" Label="Enter Query (JSON Format)" Required="True"
Value="{"match_all": { } }"
HelpLink="https://www.elastic.co/guide/en/elasticsearch/reference/6.8/query-dsl-match-query.html"
Options="All Records={"match_all": { } };Record where comment or name contains TV word={"query_string": {"query": "comment:TV OR name:TV"} };Record with comment field (attribute exists)={"query_string": {"query": "_exists_:comment"} }"
/>
</Params>
<OutputColumns>
<Column Name="count" DataType="DT_I8" />
</OutputColumns>
</EndPoint>
<!--=====================================
========= INSERT DOCUMENTS ==========
=====================================-->
<EndPoint Name="insert_documents" Label="Insert documents" Desc="Insert documents"
Url="/_bulk" Method="POST" ContentType="application/json" Filter="items[*]"
DotAsPath="True" JsonRowFormat="Multicontent"
UseRowLevelHeaderFooter="True"
RowFooter="\n"
BatchSize="2000"
IncludeParentColumns="True"
>
<Params>
<Param Name="Index" />
<Param Name="Alias" Hidden="True" />
<Param Name="DoNotAddMultiContentSeparator" Type="Property" Value="True" />
<Param Name="RowHeaderFooterContinueOnError" Type="Property" Value="True" />
<Param Name="RowHeader" NoPlaceholder="True" Value="" ValueTemplate="{ "create" : { "_index": "[$Index$]" <<<%_id%>|~| |~|, "_id":"$1",FUN_IF_NULL_OR_EMPTY>> } }\n" Type="Property"/>
</Params>
<Body>{$rows$}</Body>
<InputColumns>
<Column Name="_id" Key="True" ExcludeFromRowMap="True" DataType="DT_WSTR" Length="150" />
<Column Name="[$parent.Pivot_Path$]"
Expand="True"
DataEndPoint="get_index_metadata"
DataEndPointParameters="Index=[$Index$];Alias=[$Alias$]"
ColumnInfoMap="Name=Pivot_Name"
DataTypeMap="DT_WSTR=text;DT_I8=long"
/>
</InputColumns>
<OutputColumns>
<Column Name="P_errors" Label="ErrorFound" DataType="DT_BOOL" />
<Column Name="create._id" Label="Id" DataType="DT_WSTR" Length="50"/>
<Column Name="create._index" Label="Index" DataType="DT_WSTR" Length="150"/>
<Column Name="create._type" Label="Type" DataType="DT_WSTR" Length="50"/>
<Column Name="create.error.index_uuid" Label="IndexUuid" DataType="DT_WSTR" Length="50"/>
<Column Name="create.error.reason" Label="Reason" DataType="DT_WSTR" Length="4000"/>
<Column Name="create.error.type" Label="ErrorType" DataType="DT_WSTR" Length="250"/>
<Column Name="create.status" Label="HttpStatus" DataType="DT_I4"/>
</OutputColumns>
</EndPoint>
<!--=====================================
========= UPDATE DOCUMENTS ==========
=====================================-->
<EndPoint Name="update_documents" Label="Update documents" Desc="Update documents"
Url="/_bulk" Method="POST" ContentType="application/json" Filter="items[*]"
DotAsPath="True" JsonRowFormat="Multicontent"
RowFooter="} \n"
BatchSize="2000"
IncludeParentColumns="True"
>
<Params>
<Param Name="Index"/>
<Param Name="Alias" Hidden="True" />
<Param Name="DoNotAddMultiContentSeparator" Type="Property" Value="True" />
<Param Name="RowHeaderFooterContinueOnError" Type="Property" Value="True" />
<Param Name="RowHeader" NoPlaceholder="True" Value="" ValueTemplate="{ "update" : { "_index": "[$Index$]" <<<%_id%>|~| |~|, "_id": "$1",FUN_IF_NULL_OR_EMPTY>> } }\n{ "doc": " Type="Property"/>
</Params>
<Body>{$rows$}</Body>
<InputColumns>
<Column Name="_id" Key="True" ExcludeFromRowMap="True" DataType="DT_WSTR" Length="150" />
<Column Name="[$parent.Pivot_Name$]"
Expand="True"
DataEndPoint="get_index_metadata"
DataEndPointParameters="Index=[$Index$]"
ColumnInfoMap="Name=Pivot_Path"
DataTypeMap="DT_WSTR=text;DT_I8=long"
/>
</InputColumns>
<OutputColumns>
<Column Name="P_errors" Label="ErrorFound" DataType="DT_BOOL" />
<Column Name="update._id" Label="Id" DataType="DT_WSTR" Length="50"/>
<Column Name="update._index" Label="Index" DataType="DT_WSTR" Length="150"/>
<Column Name="update._type" Label="Type" DataType="DT_WSTR" Length="50"/>
<Column Name="update.error.index_uuid" Label="IndexUuid" DataType="DT_WSTR" Length="50"/>
<Column Name="update.error.reason" Label="Reason" DataType="DT_WSTR" Length="4000"/>
<Column Name="update.error.type" Label="ErrorType" DataType="DT_WSTR" Length="250"/>
<Column Name="update.status" Label="HttpStatus" DataType="DT_I4"/>
</OutputColumns>
</EndPoint>
<!--=====================================
========= UPSERT DOCUMENTS ==========
=====================================-->
<EndPoint Name="upsert_documents" Label="Upsert documents" Desc="Upserts documents"
Url="/_bulk" Method="POST" ContentType="application/json" Filter="items[*]"
DotAsPath="True" JsonRowFormat="Multicontent"
RowFooter="\n"
BatchSize="2000"
IncludeParentColumns="True"
>
<Params>
<Param Name="Index"/>
<Param Name="Alias" Hidden="True" />
<Param Name="RowHeaderFooterContinueOnError" Type="Property" Value="True" />
<Param Name="RowHeader" NoPlaceholder="True" Value="" ValueTemplate="{ "index" : { "_index": "[$Index$]" <<<%_id%>|~| |~|, "_id":"$1",FUN_IF_NULL_OR_EMPTY>> } }\n" Type="Property"/>
</Params>
<Body>{$rows$}</Body>
<InputColumns>
<Column Name="_id" Key="True" ExcludeFromRowMap="True" DataType="DT_WSTR" Length="150" />
<Column Name="[$parent.Pivot_Name$]"
Expand="True"
DataEndPoint="get_index_metadata"
DataEndPointParameters="Index=[$Index$];Alias=[$Alias$]"
ColumnInfoMap="Name=Pivot_Name"
DataTypeMap="DT_WSTR=text;DT_I8=long"
/>
</InputColumns>
<OutputColumns>
<Column Name="P_errors" Label="ErrorFound" DataType="DT_BOOL" />
<Column Name="index._id" Label="Id" DataType="DT_WSTR" Length="50"/>
<Column Name="index._index" Label="Index" DataType="DT_WSTR" Length="150"/>
<Column Name="index._type" Label="Type" DataType="DT_WSTR" Length="50"/>
<Column Name="index.error.index_uuid" Label="IndexUuid" DataType="DT_WSTR" Length="50"/>
<Column Name="index.error.reason" Label="Reason" DataType="DT_WSTR" Length="4000"/>
<Column Name="index.error.type" Label="ErrorType" DataType="DT_WSTR" Length="250"/>
<Column Name="index.status" Label="HttpStatus" DataType="DT_I4"/>
</OutputColumns>
</EndPoint>
<!--=====================================
======== DELETE DOCUMENTS ===========
=====================================-->
<EndPoint Name="delete_documents" Label="Delete documents" Desc="Deletes documents"
Url="/_bulk" Method="POST" ContentType="application/json"
DotAsPath="True" JsonRowFormat="Multicontent"
Body="{$rows$}"
UseRowLevelHeaderFooter="True"
RowFooter="\n"
BatchSize="2000"
Filter="$.items[*]"
IncludeParentColumns="True"
>
<Params>
<Param Name="DoNotAddMultiContentSeparator" Type="Property" Value="True" />
<Param Name="Index" Type="Placeholder"/>
</Params>
<LayoutMap>
<![CDATA[<?xml version="1.0" encoding="utf-8"?>
<settings>
<dataset id="root" readfrominput="True" />
<map name="delete">
<map name="_id" src="_id" />
<map name="_index" value="[$Index,FUN_XMLENC$]" />
</map>
</settings>]]>
</LayoutMap>
<InputColumns>
<Column Name="_id" Key="True" ExcludeFromRowMap="True" DataType="DT_WSTR" Length="150" />
</InputColumns>
<OutputColumns>
<Column Name="P_errors" Label="ErrorFound" DataType="DT_BOOL" />
<Column Name="delete._id" Label="Id" DataType="DT_WSTR" Length="50"/>
<Column Name="delete._index" Label="Index" DataType="DT_WSTR" Length="150"/>
<Column Name="delete._type" Label="Type" DataType="DT_WSTR" Length="50"/>
<Column Name="delete._version" Label="Version" DataType="DT_I4"/>
<Column Name="delete.result" Label="Result" DataType="DT_WSTR" Length="4000"/>
<Column Name="delete._seq_no" Label="SequenceNo" DataType="DT_I4"/>
<Column Name="delete._primary_term" Label="PrimaryTerm" DataType="DT_I4"/>
<Column Name="delete.status" Label="HttpStatus" DataType="DT_I4"/>
</OutputColumns>
</EndPoint>
</EndPoints>
<Tables>
<Table Name="Indexes" SelectEndPoint="list_indexes" />
<Table Name="Metadata" SelectEndPoint="get_index_metadata" />
<Table Name="[$parent.index$]"
Expand="True"
Group="Index"
SelectEndPoint="get_documents"
LookupEndPoint="get_document"
UpdateEndPoint="update_documents"
UpsertEndPoint="upsert_documents"
DeleteEndPoint="delete_documents"
InsertEndPoint="insert_documents"
DataEndPoint="list_indexes">
<Params>
<Param Name="Index" Value="[$parent.index$]" Hidden="True"/>
</Params>
</Table>
<Table Name="[$parent.Pivot_Name$]"
Group="Alias"
Expand="True"
SelectEndPoint="get_documents"
LookupEndPoint="get_document"
UpdateEndPoint="update_documents"
UpsertEndPoint="upsert_documents"
DeleteEndPoint="delete_documents"
InsertEndPoint="insert_documents"
DataEndPoint="list_aliases">
<Params>
<Param Name="Index" Value="[$parent.Pivot_Path$]" Hidden="True"/>
<Param Name="Alias" Value="[$parent.Pivot_Name$]" Hidden="True"/>
</Params>
</Table>
</Tables>
<!--=====================================
============ EXAMPLES ===============
=====================================-->
<!-- LIST INDEXES -->
<Examples>
<Example Group="ODBC" Label="Create a new index (i.e. Table)" Desc="Create a new index (i.e. Create a new table). To trow error if table exists you can set ContineOnErrorForStatusCode=0">
<Code>
<![CDATA[SELECT * FROM create_index WITH(Name='my_new_index_name', ContineOnErrorForStatusCode=1)]]>
</Code>
</Example>
<Example Group="ODBC" Label="Delete an exising index (i.e. Table)" Desc="Delete an exising index. It it exists it will show status code 400">
<Code>
<![CDATA[SELECT * FROM delete_index WITH(Name='my_index_name', ContineOn404Error=1 )]]>
</Code>
</Example>
<Example Group="ODBC" Label="Generic API Call for ElasticSearch" Desc="When EndPoint not defined and you like to call some API use this way. Below example shows how to call CREATE INDEX API generic way. See other generic API call examples.">
<Code>
<![CDATA[SELECT * FROM generic_request
WITH(Url='/my_index_name'
, RequestMethod='PUT'
-- , Body='{}'
-- , Headers='X-Hdr1:aaa || x-HDR2: bbb'
, Meta='acknowledged:bool'
)]]>
</Code>
</Example>
<Example Group="ODBC" Label="List indexes" Desc="Lists indexes" Default="True">
<Code>
<![CDATA[SELECT * FROM Indexes]]>
</Code>
</Example>
<!-- GET INDEX METADATA -->
<Example Group="ODBC" Label="Get index metadata" Desc="Gets index metadata">
<Code>
<![CDATA[SELECT * FROM get_index_metadata WITH (Index='my_index_name')]]>
</Code>
</Example>
<!-- GET DOCUMENTS FROM INDEX -->
<Example Group="ODBC" Label="Read ElasticSearch documents from Index (all or with filter)" Desc="Gets documents by index name (i.e. Table name) or alias name (i.e. View name). Using WHERE clause invokes client side engine so try to avoid WHERE clause and use WITH clause QUERY attribute. Use search endpoint instead to invoke query.">
<Code>
<![CDATA[SELECT * FROM MyIndexOrAliasName --WITH(Query='{"match": { "PartNumber" : "P50" } }')]]>
</Code>
</Example>
<!-- GET DOCUMENTS FROM INDEX -->
<Example Group="ODBC" Label="Read ElasticSearch documents from Alias (all or with filter)" Desc="Gets documents by index name (i.e. Table name) or alias name (i.e. View name). Using WHERE clause invokes client side engine so try to avoid WHERE clause and use WITH clause QUERY attribute. Use search endpoint instead to invoke query.">
<Code>
<![CDATA[SELECT * FROM MyIndexOrAliasName --WITH(Query='{"match": { "PartNumber" : "P50" } }')]]>
</Code>
</Example>
<!-- Search DOCUMENTS from Index-->
<Example Group="ODBC" Label="Search documents from Index using ElasticSearch Query language" Desc="Below example shows how to search on a comment field for TV word anywhere in the text for Index named MyIndexOrAliasName (it can be index name or alias name). For more information on ElasticSearch Query expression check this link https://www.elastic.co/guide/en/elasticsearch/reference/6.8/query-dsl-match-query.html">
<Code>
<![CDATA[
SELECT * FROM MyIndexOrAliasName WITH(Query='{"match": { "comment" : "TV" } }')
--or use below - slight faster (avoids table / alias list validation)
--SELECT * FROM search WITH(Index='MyIndexName', Query='{"match": { "comment" : "TV" } }')
--SELECT * FROM search WITH(Index='MyIndexName', Alias='MyAliasName', Query='{"match": { "comment" : "TV" } }')
]]>
</Code>
</Example>
<!-- Search DOCUMENTS from Alias-->
<Example Group="ODBC" Label="Search documents from Alias using ElasticSearch Query language" Desc="Below example shows how to search on Alias rather than Index name. Alias is build on index (consider like a view in RDBMS). This example filtes data from Alias with some condition in the Query Text. For more information on ElasticSearch Query expression check this link https://www.elastic.co/guide/en/elasticsearch/reference/6.8/query-dsl-match-query.html">
<Code>
<![CDATA[
SELECT * FROM MyAliasName WITH(Query='{"match": { "comment" : "TV" } }')
--or use search endpoint then you must supply both Index name and Alias name
--calling /search endpoint in FROM clause is slight faster (avoids table / alias list validation)
--SELECT * FROM search WITH(Index='MyIndexName',Index='MyAliasName', Query='{"match": { "comment" : "TV" } }')
]]>
</Code>
</Example>
<Example Group="ODBC" Label="Count ElasticSearch index documents using ElasticSearch Query language" Desc="Below example shows how to get just count of documents from Index (single, multiple or all index). Optionally you can supply expression to filter. For more information on ElasticSearch Query expression check this link https://www.elastic.co/guide/en/elasticsearch/reference/6.8/query-dsl-match-query.html">
<Code>
<![CDATA[
SELECT * FROM count WITH(Index='MyIndexOrAliasName') --//get count of documents in index / alias named MyIndexOrAliasName
SELECT * FROM count WITH(Index='*') --//get count of documents in all indices (total distinct _id found across all indices + alias)
SELECT * FROM count WITH(Index='MyIndex1,MyIndex2,MyAlias1,MyAlias2')--//get count of documents in indices named MyIndex1, MyIndex2 and Alias named MyAlias1,MyAlias2
SELECT * FROM count WITH(Index='MyIndexOrAliasName', Query='{"match": { "comment" : "TV" } }') --//get count of documents in MyIndex where comment field contains word "TV"
]]>
</Code>
</Example>
<Example Group="ODBC" Label="Count ElasticSearch alias documents using ElasticSearch Query language" Desc="Below example shows how to get just count of documents from Alias (single, multiple or all alias). Optionally you can supply expression to filter. For more information on ElasticSearch Query expression check this link https://www.elastic.co/guide/en/elasticsearch/reference/6.8/query-dsl-match-query.html">
<Code>
<![CDATA[
SELECT * FROM count WITH(Index='MyIndexOrAliasName') --//get count of documents in index / alias named MyIndexOrAliasName
SELECT * FROM count WITH(Index='*') --//get count of documents in all indices (total distinct _id found across all indices + alias)
SELECT * FROM count WITH(Index='MyIndexOrAlias1,MyIndexOrAlias2') --//get count of documents in MyIndex1 and MyIndex2
SELECT * FROM count WITH(Index='MyIndex', Query='{"match": { "comment" : "TV" } }') --//get count of documents in Index named MyIndex where comment field contains word "TV"
SELECT * FROM count WITH(Index='MyAlias', Query='{"match": { "comment" : "TV" } }') --//get count of documents in Alias named MyAlias where comment field contains word "TV"
]]>
</Code>
</Example>
<!-- Search DOCUMENTS-->
<Example Group="ODBC" Label="Using JSON Array / Value functions" Desc="Below example shows how to select specific elements from value array or use JSON PATH expression to extract from document array">
<Code>
<![CDATA[SELECT _id
, JSON_ARRAY_FIRST(colors) as first_color
, JSON_ARRAY_LAST(colors) as last_color
, JSON_ARRAY_NTH(colors,3) as third_color
, JSON_VALUE(locationList,'$.locationList[0].country') as first_preferred_country
, JSON_VALUE(locationList,'$.locationList[?(@country=='India')].capital as capital_of_india
FROM shop WHERE _Id='1']]>
</Code>
</Example>
<!-- INSERT DOCUMENTS INTO INDEX -->
<Example Group="ODBC" Label="Insert documents into index with _id autogenerated" Desc="When you dont supply _id column value, ElasticSearch will generate it automatically for you.">
<Code>
<![CDATA[INSERT INTO MyIndex([MyCol1], [MyCol2] ) VALUES (100, 'A1')]]>
</Code>
</Example>
<!-- INSERT DOCUMENTS INTO INDEX with _id-->
<Example Group="ODBC" Label="Insert documents into index with your own _id" Desc="Inserts documents into index with _id column. _id is string datatype so can be ">
<Code>
<![CDATA[INSERT INTO MyIndex(_id, [MyCol1], [MyCol2] ) VALUES ('A1234', 100, 'A1')]]>
</Code>
</Example>
<!-- INSERT DOCUMENTS INTO INDEX with _id-->
<Example Group="ODBC" Label="Insert documents using nested attribute and raw fragments (JSON sub-documents, arrays)"
Desc="This example produces JSON document like this {"_id": "some_auto_generated_id" , "Location": { "City" : "Atlanta" , "ZipCode" : "30060" },"ColorsArray ": ["Red", "Blue", "Green"],"SomeNestedDoc": { "Col1" : "aaa" , "Col2" : "bbb" , "Col2" : "ccc" }} . Notice that how Column name with Dot translated into nested Columns (i.e. City, ZipCode) and Prefix raw:: allowed to treat value as array or sub document.">
<Code>
<![CDATA[INSERT INTO MyIndexName ([Location.City], [Location.ZipCode], [raw::ColorsArray], [raw::SomeNestedDoc] )
VALUES ('A1234', 'Atlanta', '30060', '["red","green","blue"]', '{"Col1":"aaa","Col2":"bbb","Col3":"ccc"}' )]]>
</Code>
</Example>
<!-- INSERT RAW DOCUMENT-->
<Example Group="ODBC" Label="Insert raw document (_rawdoc_ usage)" Desc="This example shows how to insert document(s) in a raw format. When you use column name _rawdoc_ then its treated as RAW body. Notice that we use @ before string literal in value. This allow to use escape sequence (in this case \n for new line)." >
<Code>
<![CDATA[INSERT INTO shop(_RAWDOC_)
VALUES(@'{"create":{"_index":"shop","_id":"1"}}\n{"name":"record-1","colors":["yellow","orange"]}\n{"create":{"_index":"shop","_id":"2"}}\n{"name":"record-2","colors":["red","blue"]}\n')]]>
</Code>
</Example>
<!-- UPDATE DOCUMENTS IN INDEX -->
<Example Group="ODBC" Label="Update documents in index" Desc="Updates documents in index">
<Code>
<![CDATA[UPDATE MyIndex
SET Col1 = 'NewValue-1', Col2 = 'NewValue-2'
WHERE _Id = 'A1234' ]]>
</Code>
</Example>
<Example Group="ODBC" Label="Update raw document (_rawdoc_ usage)" Desc="This example shows how to update document(s) in a raw format. When you use column name _rawdoc_ then its treated as RAW body. Notice that we use @ before string literal in value. This allow to use escape sequence (in this case \n for new line)." >
<Code>
<![CDATA[UPDATE shop SET _rawdoc_ = @'{"update": {"_index": "shop", "_id": "1"}}\n{ "doc": {"colors":["yellow","orange"] } }\n{"update": {"_index": "shop", "_id": "2"}}\n{ "doc": {"colors":["yellow","blue"] } }\n']]>
</Code>
</Example>
<!-- UPDATE DOCUMENTS IN INDEX -->
<Example Group="ODBC" Label="Update array or sub document" Desc="This example shows how to update Array / nested Sub-document by adding raw:: prefix infront of column name to treat column as json fragment">
<Code>
<![CDATA[UPDATE MyIndex
SET name = 'abcd', [raw::colors]='["yellow","red"]', [raw::location]='{x:10, y:20}'
WHERE _id='1' ]]>
</Code>
</Example>
<!-- DELETE DOCUMENTS FROM INDEX -->
<Example Group="ODBC" Label="Delete documents from index" Desc="Deletes documents from index">
<Code>
<![CDATA[DELETE MyIndex WHERE _id = 'A1234']]>
</Code>
</Example>
</Examples>
</ApiConfig>
