Skip to content

Cron Connector

The Cron connector schedules data release based on cron expressions.

Connector Type: MeddleCron

Release all accumulated data at scheduled times:

{
"type": "MeddleCron",
"config": {
"mode": "Default",
"expression": "0 */5 * * * *",
"maxRetained": 100,
"timezone": "Europe/Rome"
}
}

Deduplicate data by key before release:

{
"type": "MeddleCron",
"config": {
"mode": "UniqueKey",
"expression": "0 0 * * * *",
"uniqueKey": "sensor_id",
"maxRetained": 1000
}
}

Deduplicate but keep records without the unique key:

{
"type": "MeddleCron",
"config": {
"mode": "UniqueKeyKeepMissing",
"expression": "0 30 * * * *",
"uniqueKey": "device_id",
"maxRetained": 500
}
}

Format: second minute hour day month weekday

0 */5 * * * * Every 5 minutes
0 0 * * * * Every hour
0 0 0 * * * Every day at midnight
0 30 9 * * 1-5 At 9:30 AM on weekdays
0 0 12 * * 0 At noon on Sundays
0 0 */6 * * * Every 6 hours
0 15 10 * * * At 10:15 AM every day
  • Second: 0-59
  • Minute: 0-59
  • Hour: 0-23
  • Day: 1-31
  • Month: 1-12
  • Weekday: 0-6 (0 = Sunday)
  • * - Any value
  • */n - Every n units
  • n-m - Range from n to m
  • n,m - Specific values
  • mode: Default, UniqueKey, or UniqueKeyKeepMissing
  • expression: Cron expression
  • maxRetained: Maximum payloads to retain in memory
  • timezone: Timezone for scheduling (e.g., “Europe/Rome”, “America/New_York”)
  • uniqueKey: (UniqueKey modes) Field to use for deduplication
{
"type": "MeddleCron",
"config": {
"mode": "Default",
"expression": "0 0 * * * *",
"maxRetained": 1000,
"timezone": "UTC"
}
}
{
"type": "MeddleCron",
"config": {
"mode": "UniqueKey",
"expression": "0 0 0 * * *",
"uniqueKey": "machine_id",
"maxRetained": 5000
}
}
{
"type": "MeddleCron",
"config": {
"mode": "Default",
"expression": "0 0 9-17 * * 1-5",
"maxRetained": 500,
"timezone": "Europe/Rome"
}
}
  • Set maxRetained to prevent memory issues
  • Use UniqueKey mode to avoid duplicate data
  • Choose appropriate timezone for your use case
  • Test expressions with online cron calculators
  • Merge - Time-based data combination
  • Filter - Filter before scheduling