The workflow JSON
Copy or download the full n8n JSON below. Paste it into a new n8n workflow, add your credentials, activate. Full import guide →
{
"id": "vkaSv6LyosTreiWL",
"name": "50_560_JOB_MONITOR",
"active": true,
"settings": {
"executionOrder": "v1"
},
"nodes": [
{
"id": "df0bfeb1-eb76-4833-bc96-7c3d98b4a364",
"name": "Trigger: t\u00e4glich 07:30",
"type": "n8n-nodes-base.scheduleTrigger",
"typeVersion": 1.2,
"position": [
0,
0
],
"parameters": {
"rule": {
"interval": [
{
"field": "cronExpression",
"expression": "30 7 * * 1-5"
}
]
}
}
},
{
"id": "1dcdcc9b-5d13-4379-b881-2ccf384868a9",
"name": "Adzuna KI-Manager",
"type": "n8n-nodes-base.httpRequest",
"typeVersion": 4.2,
"position": [
240,
0
],
"parameters": {
"method": "GET",
"url": "https://api.adzuna.com/v1/api/jobs/de/search/1",
"sendQuery": true,
"queryParameters": {
"parameters": [
{
"name": "app_id",
"value": "={{ $env.ADZUNA_APP_ID }}"
},
{
"name": "app_key",
"value": "={{ $env.ADZUNA_APP_KEY }}"
},
{
"name": "results_per_page",
"value": "20"
},
{
"name": "what",
"value": "KI Manager Automatisierung"
},
{
"name": "where",
"value": "Frankfurt"
},
{
"name": "distance",
"value": "80"
},
{
"name": "sort_by",
"value": "date"
}
]
}
}
},
{
"id": "7f8a5d9a-9096-4582-9322-b5ed856f592f",
"name": "Adzuna AI-Automation",
"type": "n8n-nodes-base.httpRequest",
"typeVersion": 4.2,
"position": [
240,
200
],
"parameters": {
"method": "GET",
"url": "https://api.adzuna.com/v1/api/jobs/de/search/1",
"sendQuery": true,
"queryParameters": {
"parameters": [
{
"name": "app_id",
"value": "={{ $env.ADZUNA_APP_ID }}"
},
{
"name": "app_key",
"value": "={{ $env.ADZUNA_APP_KEY }}"
},
{
"name": "results_per_page",
"value": "20"
},
{
"name": "what",
"value": "Head of AI Automation"
},
{
"name": "where",
"value": "Hessen"
},
{
"name": "sort_by",
"value": "date"
}
]
}
}
},
{
"id": "61fd276b-4250-4b80-84f3-1dcba9de2edf",
"name": "Merge",
"type": "n8n-nodes-base.merge",
"typeVersion": 3,
"position": [
240,
100
],
"parameters": {
"mode": "combine",
"combineBy": "combineAll",
"options": {}
}
},
{
"id": "6b333daf-be87-4d0c-a068-2a96ef2a2f3f",
"name": "Format & Deduplicate",
"type": "n8n-nodes-base.code",
"typeVersion": 2,
"position": [
480,
100
],
"parameters": {
"jsCode": "const seen=new Set(), out=[];\nfor(const item of $input.all()){\n for(const j of (item.json.results||[])){\n if(!seen.has(j.id)){\n seen.add(j.id);\n out.push({json:{\n job_id: j.id,\n title: j.title,\n company: j.company?.display_name || '?',\n location: j.location?.display_name || '',\n salary_min: j.salary_min || 0,\n salary_max: j.salary_max || 0,\n salary: j.salary_min\n ? Math.round(j.salary_min/1000)+'k-'+Math.round(j.salary_max/1000)+'k \u20ac'\n : 'k.A.',\n desc: (j.description||'').slice(0,150),\n url: j.redirect_url,\n created: j.created\n }});\n }\n }\n}\nreturn out.slice(0, 25);"
}
},
{
"id": "ce65155b-045c-4973-8581-22d6fac1c868",
"name": "Batch f\u00fcr Gemini",
"type": "n8n-nodes-base.code",
"typeVersion": 2,
"position": [
720,
100
],
"parameters": {
"jsCode": "// Alle Items einsammeln und als EINEN Batch-Prompt aufbauen\nconst jobs = $input.all().map((item, i) => ({\n i,\n id: item.json.job_id,\n title: item.json.title,\n company: item.json.company,\n location: item.json.location,\n salary: item.json.salary,\n desc: item.json.desc\n}));\n\nconst prompt = `Du bist ein Job-Matching-Assistent f\u00fcr Timo G\u00f6tz.\nProfil: KI/Automation-Manager, Standort Bad Homburg (PLZ 61279), Zielgehalt 70-85k\u20ac, Umkreis max 80km.\n\nBewerte jeden der folgenden ${jobs.length} Jobs. Antworte AUSSCHLIESSLICH mit validem JSON-Array:\n[{\"i\":0,\"score\":8,\"match\":\"hoch\",\"note\":\"...max 12 W\u00f6rter...\"},...]\n\nJobs:\n${jobs.map(j => `[${j.i}] ${j.title} | ${j.company} | ${j.location} | ${j.salary}`).join('\\n')}`;\n\n// Alle Job-Daten als Kontext weitergeben + Prompt\nreturn [{json: {\n prompt,\n jobs, // f\u00fcr sp\u00e4teres Merging\n}}];"
}
},
{
"id": "1ac5a27b-f0a9-467d-9f04-2c2128c5bb08",
"name": "Gemini: Batch-Bewertung",
"type": "n8n-nodes-base.httpRequest",
"typeVersion": 4.2,
"position": [
960,
100
],
"parameters": {
"method": "POST",
"url": "https://generativelanguage.googleapis.com/v1beta/models/gemini-2.5-flash:generateContent",
"sendQuery": true,
"queryParameters": {
"parameters": [
{
"name": "key",
"value": "={{ $env.GEMINI_API_KEY }}"
}
]
},
"sendBody": true,
"contentType": "json",
"body": "={{ JSON.stringify({contents:[{parts:[{text: $json.prompt}]}], generationConfig:{responseMimeType:'application/json'}}) }}"
}
},
{
"id": "5d826cf1-23db-4145-af4a-5eb5d8e1a3e5",
"name": "Parse & Filter Score>=6",
"type": "n8n-nodes-base.code",
"typeVersion": 2,
"position": [
1200,
100
],
"parameters": {
"jsCode": "// Gemini-Antwort parsen\nconst raw = $input.first().json;\nconst text = raw.candidates?.[0]?.content?.parts?.[0]?.text || '[]';\nconst jobs = $input.first().json.jobs || []; // jobs aus vorherigem Schritt\n\nlet ratings = [];\ntry {\n const clean = text.replace(/```json|```/g, '').trim();\n ratings = JSON.parse(clean);\n} catch(e) {\n // Fallback: versuche Array aus Text zu extrahieren\n const match = text.match(/\\[.*\\]/s);\n if (match) {\n try { ratings = JSON.parse(match[0]); } catch(e2) {}\n }\n}\n\n// Jobs mit Scores mergen und filtern\nconst out = [];\nfor (const r of ratings) {\n if ((r.score || 0) >= 6) {\n const job = jobs.find(j => j.i === r.i);\n if (job) {\n out.push({ json: {\n ...job,\n score: r.score,\n match: r.match,\n note: r.note,\n url: `https://www.adzuna.de/jobs/details/${job.id}`,\n source: 'adzuna'\n }});\n }\n }\n}\n\nreturn out.length > 0 ? out : [];"
}
},
{
"id": "c451802a-629e-476f-b514-c8adb3fa1051",
"name": "Telegram Digest",
"type": "n8n-nodes-base.httpRequest",
"typeVersion": 4.2,
"position": [
1440,
100
],
"parameters": {
"method": "POST",
"url": "=https://api.telegram.org/bot{{ $env.TELEGRAM_BOT_TOKEN }}/sendMessage",
"sendBody": true,
"contentType": "json",
"body": {
"chat_id": "={{ $env.TELEGRAM_ALLOWED_USER_ID }}",
"parse_mode": "Markdown",
"disable_web_page_preview": true,
"text": "={{ '\ud83c\udfaf *Job-Monitor ' + new Date().toLocaleDateString('de-DE') + '* \u2014 ' + $input.all().length + ' Treffer\\n\\n' + $input.all().slice(0,6).map((j,i)=>`${i+1}\\. *${j.json.title}*\\n\ud83c\udfe2 ${j.json.company} | \ud83d\udccd ${j.json.location}\\n\ud83d\udcb0 ${j.json.salary} | \u2b50 ${j.json.score}/10\\n\ud83d\udca1 ${j.json.note}\\n\ud83d\udd17 ${j.json.url}`).join('\\n\\n') }}"
}
}
},
{
"id": "b65d7e2d-1f96-49c7-9366-e33cb93e0138",
"name": "NocoDB: Job speichern",
"type": "n8n-nodes-base.httpRequest",
"typeVersion": 4.2,
"position": [
1440,
260
],
"parameters": {
"method": "POST",
"url": "https://directus.automation-plus-ki.de/items/130_agent_runs",
"sendHeaders": true,
"headerParameters": {
"parameters": [
{
"name": "Authorization",
"value": "Bearer ={{ $env.DIRECTUS_TOKEN }}"
}
]
},
"sendBody": true,
"contentType": "json",
"body": "={{ {Title: $json.title, Company: $json.company, Location: $json.location, Salary: $json.salary, Score: $json.score, Match: $json.match, Note: $json.note, URL: $json.url, Source: $json.source || 'adzuna', Job_ID: $json.job_id, Created: $json.created} }}"
}
}
],
"connections": {
"Trigger: t\u00e4glich 07:30": {
"main": [
[
{
"node": "Adzuna KI-Manager",
"type": "main",
"index": 0
},
{
"node": "Adzuna AI-Automation",
"type": "main",
"index": 0
}
]
]
},
"Adzuna KI-Manager": {
"main": [
[
{
"node": "Merge",
"type": "main",
"index": 0
}
]
]
},
"Adzuna AI-Automation": {
"main": [
[
{
"node": "Merge",
"type": "main",
"index": 1
}
]
]
},
"Merge": {
"main": [
[
{
"node": "Format & Deduplicate",
"type": "main",
"index": 0
}
]
]
},
"Format & Deduplicate": {
"main": [
[
{
"node": "Batch f\u00fcr Gemini",
"type": "main",
"index": 0
}
]
]
},
"Batch f\u00fcr Gemini": {
"main": [
[
{
"node": "Gemini: Batch-Bewertung",
"type": "main",
"index": 0
}
]
]
},
"Gemini: Batch-Bewertung": {
"main": [
[
{
"node": "Parse & Filter Score>=6",
"type": "main",
"index": 0
}
]
]
},
"Parse & Filter Score>=6": {
"main": [
[
{
"node": "Telegram Digest",
"type": "main",
"index": 0
},
{
"node": "NocoDB: Job speichern",
"type": "main",
"index": 0
}
]
]
}
}
}
Pro
For the full experience including quality scoring and batch install features for each workflow upgrade to Pro
About this workflow
50_560_JOB_MONITOR. Uses httpRequest. Scheduled trigger; 10 nodes.
Source: https://github.com/timo-goetz-ai/apki-core-platform/blob/main/automations/n8n-workflows/job-monitor/50_560_JOB_MONITOR.json — original creator credit. Request a take-down →
Related workflows
Workflows that share integrations, category, or trigger type with this one. All free to copy and import.
Proactively alert to service endpoint changes and pod/container issues (Pending, Not Ready, Restart spikes) using Prometheus metrics, formatted and sent to Slack.
HTTP Request
Tired of being let down by the Google Drive Trigger? Rather not exhaust system resources by polling every minute? Then this workflow is for you!
HTTP Request, Execute Workflow Trigger
Triggers at a regular interval or via a webhook request. Solves AWS WAF challenge then makes a request to fetch the product page. Extracts product data from the retrieved HTML page. Compares the curre
N8N Nodes Capsolver, HTTP Request
🔄 Monitor Container Images from Docker Hub or GHCR.
HTTP Request
Automatically monitor billable Kimai projects every weekday morning and receive a formatted HTML email when a project deadline is approaching or its hour budget is running low. If nothing requires att
Email Send, HTTP Request