YouTube 字幕處理與 Pinecone 向量資料寫入 (Upsert) 以建構 RAG - n8n 工作流程

使用這個強大的 n8n 工作流程,透過 Apify 自動爬取 YouTube 字幕,利用 OpenAI 嵌入 (Embeddings) 處理文本,並將資料寫入 Pinecone,以應用於 RAG 實戰。

工作流預覽

準備好自動化了嗎?

下載此 n8n 工作流程範本並立即開始使用。

適用對象

想從自己的 YouTube 頻道建立知識庫的內容創作者。
基於影片內容實作 RAG 系統的資料科學家。
需要для Apify、OpenAI 和向量資料庫整合的穩定 n8n 範本的開發者。
使用複雜 n8n 節點序列來管理資料管線的自動化專家。

總覽

這個進階的 n8n 工作流程解決了一個棘手的挑戰:將非結構化的影片內容(YouTube 字幕)轉換成適合 AI 查詢的結構化知識庫。自動化流程首先從 Airtable 獲取影片清單,接著使用 HTTP Request n8n 節點觸發外部的 Apify 服務來爬取字幕資料。關鍵在於,n8n 工作流程中加入了 Wait n8n 節點,用以處理非同步的作業完成,然後再取回結果。萃取出的字幕會經過分段和使用 OpenAI Embeddings n8n 節點進行向量化,最後寫入 (upsert) 到 Pinecone 向量資料庫。這為使用 n8n 強大的功能來建構高效能的 RAG 應用後端,提供了一個完整且可擴展的解決方案。

運作方式

此 n8n 工作流程的執行遵循兩條明確的邏輯路徑:


  1. 資料獲取與格式化 (頂部路徑):

主要流程由初始的 Airtable n8n 節點開始,用以擷取目標影片的紀錄。
Loop Over Items n8n 節點確保每支影片都能被獨立處理。
Apify NinjaPost n8n 節點發起 API 呼叫,啟動字幕爬取工作。
Wait n8n 節點會暫停 n8n 工作流程,直到 Apify 透過其 Webhook 發出工作完成的訊號。這是 n8n 中非常關鍵的觸發機制。
Get JSON TS n8n 節點用來獲取原始的字幕資料。
接著使用 JSON Stringifier 程式碼 n8n 節點和 Edit Fields n8n 節點來清理和標準化資料。
最後,Airtable1 n8n 節點會更新原始紀錄,標記該字幕已成功獲取。


  1. 向量化與寫入 (RAG 路徑):

此路徑可透過點擊 Test workflow (測試工作流程) 的 n8n 觸發器啟動(或在正式環境中使用專門的次要 n8n 觸發器)。
Airtable2 n8n 節點用來擷取已獲取的字幕文本。
Transcript Processor 程式碼 n8n 節點會進行最後的清理工作。
資料會流經 LangChain 整合節點:Default Data Loader 以及 Recursive Character Text Splitter1 n8n 節點,後者確保文本區塊的大小最適合進行向量儲存。
Embeddings OpenAI n8n 節點會利用 OpenAI API 生成高品質的向量表徵。
* Pinecone Vector Store n8n 節點執行最終的 Upsert 操作,將影片知識庫注入 Pinecone,從而完成自動化的 n8n 工作流程。

安裝指南


  1. 匯入: 複製提供的 n8n 工作流程 JSON 並匯入到您的 n8n 實例中。

  2. 認證設定: 為此 n8n 工作流程設定所需的認證:

Airtable: 為三個 Airtable n8n 節點實例設定認證(API 金鑰、Base ID、資料表名稱)。
HTTP Request: 在 Apify NinjaPost 和 Get JSON TS n8n 節點參數中填入您的 Apify API 金鑰和 Actor ID。這能確保外部服務可以被正確觸發。
OpenAI: 確保 Embeddings OpenAI n8n 節點已連接到您的 OpenAI API 金鑰認證。
Pinecone: 將 Pinecone Vector Store n8n 節點連接到您的 Pinecone API 金鑰、環境 (environment) 和索引名稱 (index name)。

  1. 程式碼節點: 檢閱 JSON Stringifier 和 Transcript Processor n8n 節點區塊內的邏輯,確保欄位對應完全符合您從 Apify 傳入的資料結構。這些自訂的腳本步驟對於 n8n 範本的正常運作至關重要。

  2. 啟用: 啟用 n8n 工作流程,或手動執行 When clicking ‘Test workflow’ (點擊測試工作流程) 的 n8n 觸發器來測試 RAG 路徑。

節點詳情

Airtable (3 個實例): 用於讀取初始影片清單,並在獲取轉錄內容後更新紀錄的狀態。是資料管理方面核心的 n8n 節點。
Loop Over Items n8n 節點: 關鍵的 n8n 邏輯流程控制,確保對從初始 Airtable n8n 節點擷取的紀錄進行依序、個別的處理。
Apify NinjaPost (HTTP Request n8n 節點): 啟動外部的爬取工作。關鍵設定在於為 Apify API 的工作啟動端點 (endpoint) 設定正確的 URL 和 Body。
Wait n8n 節點: n8n 工作流程中不可或缺的非同步處理器。它使用 Webhook 來暫停執行,直到收到來自 Apify 服務的成功回呼 (callback),完成了 n8n 工作流程中的關鍵環節。
Recursive Character Text Splitter1 n8n 節點: 關鍵的 LangChain 元件。它負責處理大型字幕的準備工作,將其分割成更小、語義上有意義的區塊,以供後續的 embeddings n8n 節點進行有效的向量化。
Embeddings OpenAI n8n 節點: 使用 OpenAI API 為文本區塊生成數值向量表徵 (embeddings)。這項準備工作對於 n8n 工作流程執行的最終 Upsert 操作是必要的。


  • Pinecone Vector Store n8n 節點: 是 RAG 資料的目的地位址 n8n 節點。設定為執行 upsert 操作,將向量化後的文本及相關的中繼資料 (metadata) 注入 Pinecone 資料庫。這是此進階 n8n 範本的最後一步。

相關 n8n 工作流程

免費

節點: 12 節點
更新时间: 2025年12月26日
建立者

I’m an automation enthusiast transforming complex processes into streamlined workflows with tools like n8n, Airtable, Apify, and Pinecone. I design integrations that extract insights and simplify tasks, empowering businesses and individuals to work smarter. Passionate about innovation and creative problem-solving, I actively share my expertise with a vibrant community.

精選*