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 →
{
"name": "03 \u2014 Publishing health monitor",
"nodes": [
{
"parameters": {
"rule": {
"interval": [
{
"field": "hours",
"hoursInterval": 1
}
]
}
},
"id": "trigger-hourly",
"name": "Every hour",
"type": "n8n-nodes-base.scheduleTrigger",
"typeVersion": 1.2,
"position": [
240,
300
]
},
{
"parameters": {
"method": "GET",
"url": "=http://host.docker.internal:4000/api/content/_meta/counts",
"options": {}
},
"id": "http-counts",
"name": "GET state counts",
"type": "n8n-nodes-base.httpRequest",
"typeVersion": 4.2,
"position": [
480,
300
]
},
{
"parameters": {
"jsCode": "const counts = $input.first().json.counts || [];\nconst byState = {};\nfor (const r of counts) byState[r.state] = r.count;\nconst failed = byState.failed || 0;\nconst stuckGenerating = byState.video_generating || 0;\nconst alert = failed >= 3 || stuckGenerating >= 5;\nreturn [{ json: { alert, failed, stuckGenerating, summary: byState } }];"
},
"id": "analyze",
"name": "Analyze health",
"type": "n8n-nodes-base.code",
"typeVersion": 2,
"position": [
720,
300
]
},
{
"parameters": {
"conditions": {
"options": {
"caseSensitive": true,
"leftValue": "",
"typeValidation": "strict"
},
"combinator": "and",
"conditions": [
{
"leftValue": "={{ $json.alert }}",
"rightValue": true,
"operator": {
"type": "boolean",
"operation": "true",
"singleValue": true
}
}
]
}
},
"id": "if-alert",
"name": "If alert",
"type": "n8n-nodes-base.if",
"typeVersion": 2.2,
"position": [
960,
300
]
},
{
"parameters": {
"method": "POST",
"url": "={{ $env.SLACK_WEBHOOK_URL }}",
"sendBody": true,
"specifyBody": "json",
"jsonBody": "={ \"text\": \":warning: *social-agent health alert*\\nFailed: \" + $json.failed + \"\\nStuck generating: \" + $json.stuckGenerating + \"\\n\\n```\" + JSON.stringify($json.summary, null, 2) + \"```\" }",
"options": {}
},
"id": "slack-alert",
"name": "Slack alert",
"type": "n8n-nodes-base.httpRequest",
"typeVersion": 4.2,
"position": [
1200,
240
]
}
],
"connections": {
"Every hour": {
"main": [
[
{
"node": "GET state counts",
"type": "main",
"index": 0
}
]
]
},
"GET state counts": {
"main": [
[
{
"node": "Analyze health",
"type": "main",
"index": 0
}
]
]
},
"Analyze health": {
"main": [
[
{
"node": "If alert",
"type": "main",
"index": 0
}
]
]
},
"If alert": {
"main": [
[
{
"node": "Slack alert",
"type": "main",
"index": 0
}
],
[]
]
}
},
"settings": {
"executionOrder": "v1"
},
"active": false,
"versionId": "1",
"tags": [
"social-agent",
"monitoring"
]
}
For the full experience including quality scoring and batch install features for each workflow upgrade to Pro
About this workflow
03 — Publishing health monitor. Uses httpRequest. Scheduled trigger; 5 nodes.
Source: https://github.com/anthonyonazure/social-agent/blob/main/n8n/workflows/03-publishing-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.
Free Support: Setting up and getting the workflow tailord to your needs. One small free adjustment included.
This workflow aims to help you and your team track your expenses with OpenAI It automatically collects your OpenAI organization’s API usage and cost data every few days and saves it to a ready-to-use
This n8n workflow automates Kubernetes root cause analysis (RCA) and incident alerting by integrating with Loki, Prometheus, and Slack. It streamlines log collection, cluster health monitoring, and AI
Keep your leadership team informed with a data-driven, automated morning briefing. This workflow pulls live metrics from HubSpot, Zendesk, and Pipedrive, then uses AI and Neural TTS to generate a prof
Automatically fetch, rank, and summarize the top financial stories from curated RSS feeds each day, then deliver a concise AI-written digest to Telegram and log the run to Google Sheets. Runs on a dai