Workers are specialized execution components that function as web services called by beVault's States orchestrator. Each Worker is designed to accomplish a specific, well-defined type of task in your data workflows.
Workers operate on a polling model: they continuously query the States orchestrator to check if there are tasks to execute. When a task is assigned to them (via a state machine), the Worker executes it with the provided parameters and then returns the result to States. Workers can be deployed alongside other beVault components or directly on the client's infrastructure, avoiding the need to expose sensitive databases or systems to the Internet.
To access data, Workers use configured Stores (dbStores for databases, fileStores for file systems). Each Worker references a Store by its name to connect to the target system and perform the requested operation (read, write, transform, etc.).
This page lists all available Workers, identified by their Activity name, along with the minimum beVault version where they are available and a brief description of their function. Workers cover a wide range of operations: exporting SQL data to CSV or JSON, bulk loading into tables, file compression/decompression, HTTP calls, file management (list, move, delete), state machine execution, BI tool refresh (Tableau, Toucan Toco), geographic address enrichment, and much more.
If you need to create your own custom workers for specific needs, check out the following How-to guide: How to create your own custom workers?
| Title | Activity | Available Since | Description |
|---|---|---|---|
| Compress / Decompress with GZip |
GZip |
Compress/Decompress GZip archives |
|
| Refresh ToucanToco |
ToucanTocoRefresh |
Refresh Toucan Toco applications |
|
| Load data into a Database Table |
SQLBulkInsert |
Load data into a Database Table (From CSV file or from DbStore) |
|
| List Files in FileStore |
ListFiles |
List files in a FileStore |
|
| Refresh Tableau Data Source |
TableauRefresh |
Refresh every data source of the specified projects on a Tableau Server |
|
| Execute State Machine |
ExecuteStateMachine |
Execute another statemachine |
|
| Move files from one filestore to another |
MoveFiles |
1.4.9 |
Move files from one filestore to another |
| Refresh Business Object Report |
BoRefresh |
Create a trigger file to refresh a business object report |
|
| Upload a file to ToucanToco |
ToucanTocoUpload |
Upload a file to Toucan Toco |
|
| Map Execution |
MapExecutions |
Execute another state machine multiple times with different output |
|
| Execute an SqlQuery into a dbstore |
SQLQuery |
Execute a Query in a dbstore |
|
| Enrich postal Addresses with Geoapify web service |
GeoLocationApi |
1.4.12 |
Enrich postal address |
| Load data into a Database Table from Json |
sqlInsertFromJSON |
Load data into a Database Table from JSON |
|
| Get the next execution dates of a CRON expression |
CronExecutionDates |
1.6.0 |
Get the next execution dates of a CRON expression |
| Export Sql query result to json |
exportToJson |
Extract data from a DbStore into a JSONfile |
|
| HTTP Request |
Http |
Execute HTTP requests |
|
| Get Authentication token for Ungerboeck |
UngerboeckToken |
1.5.0 |
Generate JWT token for ungerboeck api |
| Export Sql query result to csv |
exportToCsv |
Extract data from a DbStore into a CSV file |
|
| Delete Files in FileStores |
DeleteFiles |
Delete files in File Stores |