{"id":"6","name":"ETL pipeline","nodes":[{"name":"Twitter","type":"n8n-nodes-base.twitter","position":[300,300],"parameters":{"limit":3,"operation":"search","searchText":"=#OnThisDay","additionalFields":{}},"credentials":{"twitterOAuth1Api":"twitter_api"},"typeVersion":1,"id":"4ce873dc-9e37-4884-9c63-f68374f2bcd3","notes":"This twitter node performs automated tasks as part of the workflow."},{"name":"Postgres","type":"n8n-nodes-base.postgres","position":[1100,300],"parameters":{"table":"tweets","columns":"text, score, magnitude","returnFields":"=*"},"credentials":{"postgres":"postgres"},"typeVersion":1,"id":"ce4ec74d-9718-4a25-9152-bb37937001c4","notes":"This postgres node performs automated tasks as part of the workflow."},{"name":"MongoDB","type":"n8n-nodes-base.mongoDb","position":[500,300],"parameters":{"fields":"text","options":{},"operation":"insert","collection":"tweets"},"credentials":{"mongoDb":"mongodb"},"typeVersion":1,"id":"93fd546a-4325-4fe0-8a54-22dac85504bb","notes":"This mongoDb node performs automated tasks as part of the workflow."},{"name":"Slack","type":"n8n-nodes-base.slack","position":[1500,200],"parameters":{"text":"=🐦 NEW TWEET with sentiment score {{$json[\"score\"]}} and magnitude {{$json[\"magnitude\"]}} ⬇️\n{{$json[\"text\"]}}","channel":"tweets","attachments":[],"otherOptions":{}},"credentials":{"slackApi":"slack"},"typeVersion":1,"id":"36097c0d-2311-49b6-92c0-b20c6906a2b0","notes":"This slack node performs automated tasks as part of the workflow."},{"name":"If Node","type":"n8n-nodes-base.if","position":[1300,300],"parameters":{"conditions":{"number":[{"value1":"={{$json[\"score\"]}}","operation":"larger"}]}},"typeVersion":1,"id":"d37e9fcd-38fc-45b4-b2e8-b926497f8593","notes":"This if node performs automated tasks as part of the workflow."},{"name":"NoOp","type":"n8n-nodes-base.noOp","position":[1500,400],"parameters":{},"typeVersion":1,"id":"6967e38a-9d16-490a-87db-cd4e20483f6a","notes":"This noOp node performs automated tasks as part of the workflow."},{"name":"Google Cloud Natural Language","type":"n8n-nodes-base.googleCloudNaturalLanguage","position":[700,300],"parameters":{"content":"={{$node[\"MongoDB\"].json[\"text\"]}}","options":{}},"credentials":{"googleCloudNaturalLanguageOAuth2Api":"google_nlp"},"typeVersion":1,"id":"a544286c-1ef5-41c1-a9d0-3ba1873e65bf","notes":"This googleCloudNaturalLanguage node performs automated tasks as part of the workflow."},{"name":"Set","type":"n8n-nodes-base.set","position":[900,300],"parameters":{"values":{"number":[{"name":"score","value":"={{$json[\"documentSentiment\"][\"score\"]}}"},{"name":"magnitude","value":"={{$json[\"documentSentiment\"][\"magnitude\"]}}"}],"string":[{"name":"text","value":"={{$node[\"Twitter\"].json[\"text\"]}}"}]},"options":{}},"typeVersion":1,"id":"3ae0ba4c-9d77-46fc-9636-b05736527f8f","notes":"This set node performs automated tasks as part of the workflow."},{"name":"Cron","type":"n8n-nodes-base.cron","position":[100,300],"parameters":{"triggerTimes":{"item":[{"hour":6}]}},"typeVersion":1,"id":"4689324a-18ad-4327-a409-ac451db0e735","notes":"This cron node performs automated tasks as part of the workflow."},{"id":"error-0fa178af","name":"Error Handler","type":"n8n-nodes-base.stopAndError","typeVersion":1,"position":[1000,400],"parameters":{"message":"Workflow execution error","options":{}}}],"active":false,"settings":{"executionOrder":"v1","saveManualExecutions":true,"callerPolicy":"workflowsFromSameOwner","errorWorkflow":null,"timezone":"UTC","executionTimeout":3600,"maxExecutions":1000,"retryOnFail":true,"retryCount":3,"retryDelay":1000},"connections":{},"description":"Automated workflow: ETL pipeline. This workflow processes data and performs automated tasks.","meta":{"instanceId":"workflow-72ad3dbb","versionId":"1.0.0","createdAt":"2025-09-29T07:07:51.342926","updatedAt":"2025-09-29T07:07:51.342937","owner":"n8n-user","license":"MIT","category":"automation","status":"active","priority":"high","environment":"production"},"notes":"Excellent quality workflow: ETL pipeline. This workflow has been optimized for production use with comprehensive error handling, security, and documentation."}