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 |
|---|---|---|---|
| Refresh Business Object Report |
BoRefresh |
Create a trigger file to refresh a business object report |
|
| Get the next execution dates of a CRON expression |
CronExecutionDates |
1.6.0 |
Get the next execution dates of a CRON expression |
| Delete Files in FileStores |
DeleteFiles |
Delete files in File Stores |
|
| Execute State Machine |
ExecuteStateMachine |
Execute another statemachine |
|
| Export Sql query result to csv |
exportToCsv |
Extract data from a DbStore into a CSV file |
|
| Export Sql query result to json |
exportToJson |
Extract data from a DbStore into a JSONfile |
|
| Enrich postal Addresses with Geoapify web service |
GeoLocationApi |
1.4.12 |
Enrich postal address |
| Compress / Decompress with GZip |
GZip |
Compress/Decompress GZip archives |
|
| HTTP Request |
Http |
Execute HTTP requests |
|
| List Files in FileStore |
ListFiles |
List files in a FileStore |
|
| Map Execution |
MapExecutions |
Execute another state machine multiple times with different output |
|
| Move files from one filestore to another |
MoveFiles |
1.4.9 |
Move files from one filestore to another |
| Load data into a Database Table |
SQLBulkInsert |
Load data into a Database Table (From CSV file or from DbStore) |
|
| Load data into a Database Table from Json |
sqlInsertFromJSON |
Load data into a Database Table from JSON |
|
| Execute an SqlQuery into a dbstore |
SQLQuery |
Execute a Query in a dbstore |
|
| Refresh Tableau Data Source |
TableauRefresh |
Refresh every data source of the specified projects on a Tableau Server |
|
| Refresh ToucanToco |
ToucanTocoRefresh |
Refresh Toucan Toco applications |
|
| Upload a file to ToucanToco |
ToucanTocoUpload |
Upload a file to Toucan Toco |
|
| Get Authentication token for Ungerboeck |
UngerboeckToken |
1.5.0 |
Generate JWT token for ungerboeck api |