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": "Governed Analytics Pipeline Orchestration",
"nodes": [
{
"parameters": {
"rule": {
"interval": [
{
"field": "hours",
"hoursInterval": 24
}
]
}
},
"id": "schedule-trigger",
"name": "Schedule Trigger",
"type": "n8n-nodes-base.scheduleTrigger",
"typeVersion": 1.2,
"position": [
0,
0
],
"notes": "Adjust the interval in n8n according to the target operating cadence."
},
{
"parameters": {
"assignments": {
"assignments": [
{
"id": "pipeline-name",
"name": "pipeline_name",
"value": "governed_analytics_pipeline",
"type": "string"
},
{
"id": "environment",
"name": "environment",
"value": "local",
"type": "string"
},
{
"id": "config-path",
"name": "config_path",
"value": "config/pipeline_config.yml",
"type": "string"
},
{
"id": "input-dataset",
"name": "input_dataset_path",
"value": "data/samples/sample_governance_dataset.csv",
"type": "string"
},
{
"id": "execution-source",
"name": "execution_source",
"value": "n8n",
"type": "string"
}
]
},
"options": {}
},
"id": "set-execution-metadata",
"name": "Set Execution Metadata",
"type": "n8n-nodes-base.set",
"typeVersion": 3.4,
"position": [
260,
0
],
"notes": "Centralizes values used by command nodes. Keep secrets out of this workflow file."
},
{
"parameters": {
"command": "python -c \"from pathlib import Path; path=Path('data/samples/sample_governance_dataset.csv'); print('dataset_exists=true' if path.exists() else 'dataset_exists=false')\""
},
"id": "check-input-dataset",
"name": "Check Input Dataset",
"type": "n8n-nodes-base.executeCommand",
"typeVersion": 1,
"position": [
520,
0
],
"notes": "Checks that the sample governance dataset is available before running the governed pipeline steps."
},
{
"parameters": {
"conditions": {
"string": [
{
"value1": "={{ $json.stdout }}",
"operation": "contains",
"value2": "dataset_exists=true"
}
]
}
},
"id": "input-dataset-exists",
"name": "Input Dataset Exists?",
"type": "n8n-nodes-base.if",
"typeVersion": 1,
"position": [
780,
0
],
"notes": "True branch continues the pipeline. False branch stops execution; configure the error workflow for alerting."
},
{
"parameters": {
"command": "python scripts/run_data_quality.py --config config/pipeline_config.yml"
},
"id": "run-data-quality-checks",
"name": "Run Data Quality Checks",
"type": "n8n-nodes-base.executeCommand",
"typeVersion": 1,
"position": [
1040,
-120
]
},
{
"parameters": {
"command": "python scripts/run_lgpd_classification.py --config config/pipeline_config.yml"
},
"id": "run-lgpd-classification",
"name": "Run LGPD Classification",
"type": "n8n-nodes-base.executeCommand",
"typeVersion": 1,
"position": [
1300,
-120
]
},
{
"parameters": {
"command": "python scripts/run_privacy_risk_score.py --config config/pipeline_config.yml"
},
"id": "run-privacy-risk-scoring",
"name": "Run Privacy Risk Scoring",
"type": "n8n-nodes-base.executeCommand",
"typeVersion": 1,
"position": [
1560,
-120
]
},
{
"parameters": {
"command": "python scripts/generate_governance_docs.py --config config/pipeline_config.yml"
},
"id": "generate-governance-docs",
"name": "Generate Governance Docs",
"type": "n8n-nodes-base.executeCommand",
"typeVersion": 1,
"position": [
1820,
-120
]
},
{
"parameters": {
"command": "python scripts/register_pipeline_log.py --pipeline-name governed_analytics_pipeline --status success --message \"n8n governed analytics workflow completed\" --source n8n --config config/pipeline_config.yml"
},
"id": "register-execution-log",
"name": "Register Execution Log",
"type": "n8n-nodes-base.executeCommand",
"typeVersion": 1,
"position": [
2080,
-120
]
},
{
"parameters": {
"resource": "message",
"operation": "send",
"guildId": "PLACEHOLDER_DISCORD_GUILD_ID",
"channelId": "PLACEHOLDER_DISCORD_CHANNEL_ID",
"content": "Governed Analytics Pipeline completed successfully. Review generated logs and governance artifacts in the repository."
},
"id": "send-success-alert",
"name": "Send Success Alert",
"type": "n8n-nodes-base.discord",
"typeVersion": 2,
"position": [
2340,
-120
],
"credentials": {
"discordBotApi": {
"name": "<your credential>"
}
},
"notes": "Placeholder alert node. Replace guild/channel IDs and attach real n8n credentials inside n8n. Do not commit real credentials."
}
],
"connections": {
"Schedule Trigger": {
"main": [
[
{
"node": "Set Execution Metadata",
"type": "main",
"index": 0
}
]
]
},
"Set Execution Metadata": {
"main": [
[
{
"node": "Check Input Dataset",
"type": "main",
"index": 0
}
]
]
},
"Check Input Dataset": {
"main": [
[
{
"node": "Input Dataset Exists?",
"type": "main",
"index": 0
}
]
]
},
"Input Dataset Exists?": {
"main": [
[
{
"node": "Run Data Quality Checks",
"type": "main",
"index": 0
}
],
[]
]
},
"Run Data Quality Checks": {
"main": [
[
{
"node": "Run LGPD Classification",
"type": "main",
"index": 0
}
]
]
},
"Run LGPD Classification": {
"main": [
[
{
"node": "Run Privacy Risk Scoring",
"type": "main",
"index": 0
}
]
]
},
"Run Privacy Risk Scoring": {
"main": [
[
{
"node": "Generate Governance Docs",
"type": "main",
"index": 0
}
]
]
},
"Generate Governance Docs": {
"main": [
[
{
"node": "Register Execution Log",
"type": "main",
"index": 0
}
]
]
},
"Register Execution Log": {
"main": [
[
{
"node": "Send Success Alert",
"type": "main",
"index": 0
}
]
]
}
},
"settings": {
"executionOrder": "v1",
"errorWorkflow": "Governed Analytics Error Handler"
},
"staticData": null,
"versionId": "governed-analytics-pipeline-orchestration-template-v2",
"triggerCount": 1,
"tags": [
{
"name": "governance"
},
{
"name": "analytics-engineering"
},
{
"name": "n8n-template"
}
]
}
Credentials you'll need
Each integration node will prompt for credentials when you import. We strip credential IDs before publishing — you'll add your own.
discordBotApi
Pro
For the full experience including quality scoring and batch install features for each workflow upgrade to Pro
About this workflow
Governed Analytics Pipeline Orchestration. Uses executeCommand, discord. Scheduled trigger; 10 nodes.
Source: https://github.com/samuelmaia-analytics/Governed-Analytics-Platform/blob/main/workflows/n8n/governed_analytics_pipeline.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.
Wait Schedule. Uses spotify, supabase, compareDatasets, noOp. Scheduled trigger; 54 nodes.
Spotify, Supabase, YouTube +1
N8N. Uses github, discord, postgres. Scheduled trigger; 38 nodes.
GitHub, Discord, Postgres
This n8n template demonstrates how to automatically monitor and track username and nickname changes across your Discord server members. Perfect for community moderation, security monitoring, and maint
Discord, Data Table
🌸 Affirmation Sender + Weekly Gratitude Digest v2
Email Send, Telegram, Notion +3
I wanted a journal but never had the discipline to write one. Most of my day happens in Discord anyway, so I built this to do it for me.
Discord, HTTP Request, Notion