Elasticsearch Operation

Intergrate Directus content with an Elasticsearch cloud project or selfhosted project using Flows. This extension adds a new operation to your flows called Elasticsearch and uses an API key with full write access to create, update and delete documents in your search indexes. Elaticsearch operation is available via the Marketplace.

The operation is processed on the server side. If using localhost, elasticsearch must be on the same server.

Usage

In a Flow, select the Elasticsearch as an operation, then populate the required fields. Here is detailed information on each field.

Here are some examples on how you can use Directus to maintain an Elasticsearch index.

On Create

1. Create a flow that is triggered on item.create and choose all the collection to include.
2. Add the Elasticsearch operation and set:
   • index to {{$trigger.collection}}
   • action to Create
   • item id/key to {{$trigger.key}}
   • item data to {{$trigger.payload}}.

On Update

1. Create a flow that is triggered on item.update and choose all the collection to include.
2. Add the Elasticsearch operation and set:
   • index to {{$trigger.collection}}
   • action to Update
   • item id/key to {{$trigger.keys}}
   • item data to {{$trigger.payload}}.

On Delete

1. Create a flow that is triggered on item.delete and choose all the collection to include.
2. Add the Elasticsearch operation and set:
   • index to {{$trigger.collection}}
   • action to Delete
   • item id/key to {{$trigger.keys}}

Manual Trigger

This is useful if you want to manually index items using a manual flow.

1. Create a second flow that is triggered by another flow and set the Response body to the Data of the last operation.
2. Add the Elasticsearch operation and set:
   • index to {{$trigger.collection}}
   • action to Update
   • item id/key to {{$trigger.key}}
   • item data to {{$trigger.payload}}.
3. Create a manual flow set the following:
   • choose the collections to include
   • location to Collection only
   • leave 'Required Selection' checked
4. Add the Read Data operation with the following:
   • collection set to {{$trigger.body.collection}}
   • IDs set to {{$trigger.body.keys}}
5. Create a Script operation to transform that data into valid payloads. Copy and paste the following:

module.exports = async function(data) {
	return Array.isArray(data['$last']) ? data['$last'].map((item) => {
    	return {
            collection: data['$trigger'].body.collection,
            key: item.id,
            payload: item,
        };
    }) : [
      {
        collection: data['$trigger'].body.collection,
        key: data['$last'].id,
        payload: data['$last'],
      }
    ];
}

6. Create an operation that triggers another flow.
   • From the dropdown, cloose the flow created in step 1
   • Set the Iteration mode to serial
   • Set the Payload to {{$last}}

Now you can open any of the included collections and tick all the items to index, then click the flows icon (lightning bolt) from the right navigation bar and click the button. The label will match what you called the flow.

Check it out on NPM

@directus-labs/elasticsearch-operation

Intergrate Directus content with Elasticsearch. . Latest version: 1.0.0, last published: a month ago. Start using @directus-labs/elasticsearch-operation in your project by running `npm i @directus-labs/elasticsearch-operation`. There are no other projects in the npm registry using @directus-labs/elasticsearch-operation.

npm