Devo Sink
- Juan Tomás Alonso Nieto (Deactivated)
Description
This unit is a Sink unit type.
This unit sends past and current events to a specified my.app table in your Devo domain.
An event comes in through the in port. The event is sent to the appropriate Devo relay. Input events successfully sent to the my.app table exit via the done port without modification.
If an error occurs, the input event is enriched with new fields describing the problem, and the event is sent through the error port.
Configuration
After dragging this unit into the Flow canvas, double-click it to access its configuration options. The following table describes the configuration options of this unit:
Tab | Field | Description |
|---|---|---|
General | Name | Enter a name for the unit. It must start with a letter, and cannot contain spaces. Only letters, numbers, and underscores are allowed. |
Description | Enter a description detailing the scope of the unit. | |
Table name | Enter the name of the Devo table where you want to send the events. It must always be a my.app table. | |
Time field name | Enter the name of the event field containing the timestamp of the recent. This input allows you to send past events. When not defined or invalid, the event will be sent using the current date and time. | |
Refresh columns automatically | When toggled ON, the input event types will be separated into the following columns in the my.app destination table:
When toggled OFF, all event types will appear in one column. |
Input ports
Port | Description |
|---|---|
in | This port receives the input events to be sent to the specified my.app table. |
Output ports
Port | Description |
|---|---|
done | This port outputs the events that were successfully sent to the specified Devo my.app table, without any modification. |
error | This port outputs events that couldn't be successfully sent to the specified my.app table. Input events are enriched with two additional fields to describe the error (error and exception). |
Example
In this example, we want to create a dynamic query to send events every ten minutes to enrich the main query and send the data to a my.app table using a Devo sink unit.
To do this, we will add a Tick unit to fire events. Then, we will add a Scheduler unit to send events every 10 minutes.
Link the out port of the Tick unit to the do port of the Scheduler unit.
Next, add a Map unit to define the main query. In the Fields to add tab of the properties, add the following information:
In the Fields to remove tab, insert:
Now add a Devo Full Query unit and in the From event tab, specify the values corresponding to the input event fields, overriding previous settings.
We will send the data of the main query from the out port of the Map unit to the in port of the Devo Full Query unit.
Finally, send the data to a specific my.app table using a Devo Sink unit, linking the data port of the Devo Full Query to the in port.
After saving and starting the Flow, you must click the red button of the Tick unit to begin sending events.
Download this example
You can try this flow by downloading the following JSON file and uploading it to your domain using the Import option:
