Pipelines

If an attribute has been registered with Klevu for indexing that does not mean it is automatically sent to Klevu. It means it can be sent to Klevu. Entity data indexed to Klevu is defined in the indexing pipelines YAML files.

Klevu indexing uses Klevu’s Data Indexing JSON API. Klevu has developed a php-sdk to assist developers with integrating Klevu indexing into any PHP Platform. This php-sdk is used during indexing from Magento.

Klevu has also developed php-pipelines these are generic PHP pipelines that can be used for any purpose and are independent from Magento and the SDK.

These 2 modules are brought together via php-sdk-pipelines, adding php-sdk functionality into the pipelines.

There is a 4th module, module-m2-pipelines which integrates these new components into Magento. This handles dependency injection and adds some Magento context into the pipelines.

Create and return a new object. Example: Create an object with keys id and type

Output:

If any validation exception ValidationExceptionInterface is thrown, catch it and move on to the next stage, otherwise return the output from this stage.

Example:

Note: the stage names have been removed from this example to make it easier to read

Loop over the provided records.

Example: Iterate over all records provided into the pipeline

or get all customer groups, iterate over then, setting the current customer group at the start of each loop

Add a value to the output.

Example:

Output:

Get the value from the extraction and pass it to the next stage Example:

Output:

Transform the provided value using one or multiple transformers. Example:

Output:

Alternatively, transformations can be passed into extractions, skipping the need to add an extra stage.

Example:

Output:

Example:

If validation fails an exception of type Klevu\Pipelines\Exception\ValidationExceptionInterface will be thrown. Fallback pipelines will catch this an proceed to the next stage. See module-m2-indexing-products/etc/pipeline/attributes/images.yml

Register a variable to be used elsewhere in the pipeline.

Example: Extract the current product and then register the context as currentProduct

Then later in the pipeline (possibly in another file, even another module) the context can be used.

Output:

Log the current context. Example: module-m2-indexing/etc/pipeline/process-batch-payload.yml Take whatever the current context is (the output from the previous operation) and log it along with the message “Chunked payload” at log level “debug”.

Output (formatted to make it more readable):

When we trigger a sync from Magento, whether via cron or CLI, Klevu\Indexing\Service\EntitySyncOrchestratorService::execute is executed. This loops through all entityIndexerServices. These entityIndexerServices are injected via di.xml from each entity indexing module (module-m2-indexing-categories, module-m2-indexing-cms, module-ms-indexing-products).

e.g. from module-ms-indexing-products/etc/di.xml

The injected EntityIndexerService is a virtual type, into which we pass an EntityIndexingRecordProvider and a pipeline YAML file.