1 
2แอปพลิเคชัน production ส่วนใหญ่ต้องการงานที่ไม่เข้ากับวงจร request/response: การส่งอีเมล การประมวลผลการอัปโหลด การรัน AI pipelines การซิงค์ข้อมูลจากบุคคลที่สาม การสร้างรายงาน คำตอบดั้งเดิมคือคิว (Redis, SQS, RabbitMQ), worker fleet, scheduler และกองโค้ด glue ที่เปราะบางซึ่งจะแตกในทุกๆ การ deploy
3 
4[Trigger.dev](https://trigger.dev) ยุบ stack นั้นให้เป็น TypeScript SDK เดียว คุณเขียน functions เรียกใช้จากที่ไหนก็ได้ และแพลตฟอร์มจัดการ queueing, retries, observability, scheduling และการประมวลผลที่ทนทาน Tasks ทำงานนานเท่าที่ต้องการ - ไม่มี timeout serverless 10 วินาที ไม่มีงานที่หายไปเมื่อ redeploy
5 
6## ทำไมต้อง Trigger.dev
7 
8การเปลี่ยนแปลงในปี 2026 คือการประมวลผลที่ทนทาน Workflows ต้องอยู่รอดจากการรีสตาร์ท การ crash การ deploy และ rate limit พวกเขาต้อง stream ความคืบหน้าไปยัง UI แบบเรียลไทม์และหยุดชั่วคราวสำหรับการป้อนข้อมูลของมนุษย์ Trigger.dev ถูกสร้างขึ้นใหม่รอบๆ ข้อกำหนดเหล่านี้ในเวอร์ชัน 3 และยังคงขยายพื้นผิวโครงสร้างพื้นฐาน AI ของตน
9 
10```mermaid
11graph LR
12    App[App ของคุณ] -->|trigger| API[Trigger.dev API]
13    API --> Queue[Queue ที่ทนทาน]
14    Queue --> Worker[Worker Container]
15    Worker -->|run task| Task[โค้ด Task ของคุณ]
16    Task -->|metadata| Realtime[Realtime Stream]
17    Realtime --> UI[React UI]
18    Worker --> Storage[Run State Store]
19```
20 
21โมเดลนั้นเรียบง่าย: คุณกำหนด tasks เป็น exports, SDK รับมันมา แพลตฟอร์มจัดตารางและรันใน containers ที่แยกออกจากกันและสถานะของ run จะถูกเก็บไว้เพื่อให้คุณสามารถดำเนินการต่อ ลองใหม่และสังเกตได้
22 
23## เริ่มต้น
24 
25### เริ่มต้นโปรเจค
26 
27```bash
28npx trigger.dev@latest login
29npx trigger.dev@latest init
30```
31 
32สิ่งนี้สร้างไฟล์ `trigger.config.ts` และไดเร็กทอรี `trigger/` พร้อม tasks ตัวอย่าง ไฟล์ config คือแหล่งความจริงสำหรับโปรเจคของคุณ: ไดเร็กทอรีใดมี tasks การตั้งค่า build, lifecycle hooks และตัวเลือก runtime
33 
34```typescript
35// trigger.config.ts
36import { defineConfig } from "@trigger.dev/sdk";
37 
38export default defineConfig({
39  project: "proj_abc123",
40  runtime: "node",
41  logLevel: "log",
42  maxDuration: 3600,
43  retries: {
44    enabledInDev: true,
45    default: {
46      maxAttempts: 3,
47      factor: 2,
48      minTimeoutInMs: 1000,
49      maxTimeoutInMs: 30_000,
50    },
51  },
52  dirs: ["./trigger"],
53});
54```
55 
56### รัน tasks ในเครื่อง
57 
58```bash
59npx trigger.dev@latest dev
60```
61 
62เซิร์ฟเวอร์ dev เชื่อมต่อกับคลาวด์ ลงทะเบียน tasks ของคุณและ stream runs ผ่านโค้ดในเครื่องของคุณ คุณตั้งค่า breakpoints ใน editor ของคุณและตีถึงพวกเขาบน trigger จริง - วงรอบเดียวกันที่คุณจะใช้ในโปรเจค Node.js ปกติ
63 
64## การกำหนด Task
65 
66Task คือ object ที่ส่งออกพร้อม `id` ที่ไม่ซ้ำกันและฟังก์ชัน `run` SDK ตรวจสอบ exports ใน `dirs` และลงทะเบียนพวกเขาโดยอัตโนมัติ
67 
68```typescript
69// trigger/send-welcome-email.ts
70import { task } from "@trigger.dev/sdk";
71import { Resend } from "resend";
72 
73const resend = new Resend(process.env.RESEND_API_KEY);
74 
75export const sendWelcomeEmail = task({
76  id: "send-welcome-email",
77  retry: {
78    maxAttempts: 5,
79    factor: 1.8,
80    minTimeoutInMs: 500,
81    maxTimeoutInMs: 30_000,
82  },
83  run: async (payload: { email: string; name: string }) => {
84    const { data, error } = await resend.emails.send({
85      from: "hello@spinny.dev",
86      to: payload.email,
87      subject: `Welcome, ${payload.name}`,
88      html: `<p>Glad you are here, ${payload.name}.</p>`,
89    });
90 
91    if (error) throw error;
92    return { messageId: data?.id };
93  },
94});
95```
96 
97สามสิ่งที่ต้องสังเกต:
98 
991. **ไม่มี timeout ในตัว run.** แพลตฟอร์มจัดการเวลาประมวลผลผ่าน `maxDuration` ใน config ไม่ใช่ runtime
1002. **Throws คือ retries.** SDK จับ exceptions และรันใหม่ด้วย exponential backoff ตามนโยบาย `retry`
1013. **ค่าที่ส่งคืนถูกเก็บไว้** Tasks อื่นและ frontend ของคุณสามารถอ่าน `run.output` จากที่ไหนก็ได้
102 
103## การ Trigger Tasks
104 
105คุณเรียกใช้ task จาก backend, route API หรือ task อื่น
106 
107```typescript
108import { sendWelcomeEmail } from "@/trigger/send-welcome-email";
109 
110const handle = await sendWelcomeEmail.trigger(
111  { email: "user@example.com", name: "Alex" },
112  {
113    idempotencyKey: `welcome-${userId}`,
114    concurrencyKey: `tenant-${tenantId}`,
115    queue: { name: "emails", concurrencyLimit: 50 },
116    delay: "30s",
117    ttl: "10m",
118  }
119);
120 
121console.log(handle.id); // run_xyz - ใช้สำหรับติดตามหรือแสดงความคืบหน้า
122```
123 
124ตัวเลือกปลดล็อกพฤติกรรมจำนวนมากในการเรียกครั้งเดียว:
125 
126- **`idempotencyKey`** - หาก run ที่มี key เดียวกันมีอยู่แล้ว SDK จะส่งคืน handle ที่มีอยู่แทนการทำงานซ้ำ
127- **`concurrencyKey`** - ทำการอนุกรม runs ที่แชร์ key ดังนั้นคุณจะไม่เกิน rate limit ต่อ tenant
128- **`queue.concurrencyLimit`** - ขอบเขตทั่วโลกสำหรับ queue ในทุก keys
129- **`delay`** - กำหนดเวลา run สำหรับเวลาในอนาคต
130- **`ttl`** - หาก run ยังไม่ได้เริ่มต้นภายในเวลานั้น ให้หมดอายุโดยอัตโนมัติ
131 
132### Batch trigger
133 
134สำหรับ workload fan-out, `batchTrigger` ยอมรับ items สูงสุด 500 รายการต่อการเรียกและสร้าง run หนึ่งรายการต่อ item
135 
136```typescript
137await sendWelcomeEmail.batchTrigger(
138  newUsers.map((u) => ({
139    payload: { email: u.email, name: u.name },
140    options: { idempotencyKey: `welcome-${u.id}` },
141  }))
142);
143```
144 
145## Tasks ที่กำหนดเวลา
146 
147Cron jobs กลายเป็นการประกาศชั้นแรก Schedule เองเป็น object แยกที่คุณสามารถแนบกับ task ได้หลายครั้ง
148 
149```typescript
150// trigger/daily-digest.ts
151import { schedules } from "@trigger.dev/sdk";
152 
153export const dailyDigest = schedules.task({
154  id: "daily-digest",
155  cron: "0 9 * * *",
156  run: async (payload) => {
157    console.log("Scheduled at:", payload.timestamp);
158    console.log("Last run:", payload.lastTimestamp);
159    console.log("Timezone:", payload.timezone);
160    console.log("Next 5 runs:", payload.upcoming);
161 
162    await sendDigestForDate(payload.timestamp);
163  },
164});
165```
166 
167สำหรับ schedule ต่อ tenant - เช่น cron หนึ่งต่อลูกค้า - คุณสร้างพวกเขาแบบไดนามิกผ่าน management API
168 
169```typescript
170import { schedules } from "@trigger.dev/sdk";
171 
172await schedules.create({
173  task: "daily-digest",
174  cron: "0 9 * * *",
175  timezone: "America/New_York",
176  externalId: `customer_${customerId}`,
177  deduplicationKey: `digest-${customerId}`,
178});
179```
180 
181`deduplicationKey` ทำให้การเรียก idempotent: รันโค้ดเดิมอีกครั้งในเวลา deploy ไม่ทำให้ schedules ซ้ำกัน
182 
183## Queues, Concurrency และ Idempotency
184 
185primitives สามตัวครอบคลุมความต้องการ rate-limiting และ ordering ส่วนใหญ่
186 
187```mermaid
188graph TB
189    Trigger[trigger payload] --> IK{idempotencyKey<br/>เห็นแล้ว?}
190    IK -->|ใช่| Reuse[ส่งคืน run ที่มีอยู่]
191    IK -->|ไม่| CK[bucket concurrencyKey]
192    CK --> Q[Queue กับ<br/>concurrencyLimit]
193    Q -->|slot ว่าง| Run[รัน task]
194    Q -->|slots เต็ม| Wait[รอใน queue]
195```
196 
197รูปแบบทั่วไป: queue หนึ่งต่อ tenant ที่มี concurrency ต่อ key เล็กเพื่อเคารพ rate limit ของ vendor บวกกับ idempotency key เพื่อให้ retries ปลอดภัย
198 
199```typescript
200await syncShopifyOrders.trigger(
201  { shopId },
202  {
203    queue: { name: `shopify-${shopId}`, concurrencyLimit: 2 },
204    concurrencyKey: shopId,
205    idempotencyKey: `sync-${shopId}-${Date.now() / 60_000 | 0}`,
206  }
207);
208```
209 
210## Waits และงานที่ทำงานนาน
211 
212Tasks สามารถหยุดชั่วคราวได้โดยไม่ต้องรักษาการเชื่อมต่อหรือเผา compute แพลตฟอร์มเก็บสถานะและดำเนินการฟังก์ชันต่อเมื่อ wait เสร็จสิ้น
213 
214```typescript
215import { wait } from "@trigger.dev/sdk";
216 
217export const onboarding = task({
218  id: "onboarding",
219  run: async (payload: { userId: string }) => {
220    await sendWelcomeEmail.triggerAndWait({ userId: payload.userId });
221    await wait.for({ days: 1 });
222    await sendTipsEmail.trigger({ userId: payload.userId });
223    await wait.until({ date: oneWeekFromSignup(payload.userId) });
224    await sendUpgradeOffer.trigger({ userId: payload.userId });
225  },
226});
227```
228 
229`triggerAndWait` คือฟีเจอร์เด็ดขาด: มัน trigger task ลูกและระงับ parent จนกว่า child จะเสร็จสมบูรณ์ คุณรวบรวม tasks เหมือน async functions แต่การประสานทำงานอย่างทนทานข้ามวันหรือสัปดาห์
230 
231### Human-in-the-loop ด้วย `wait.forToken`
232 
233สำหรับขั้นตอนการอนุมัติและ AI gates, `wait.forToken` หยุดชั่วคราวจนกว่าแอปพลิเคชันของคุณจะเรียกกลับด้วยผลลัพธ์
234 
235```typescript
236import { task, wait } from "@trigger.dev/sdk";
237 
238export const publishPost = task({
239  id: "publish-post",
240  run: async (payload: { draftId: string }) => {
241    const draft = await generateAIContent(payload.draftId);
242 
243    const token = await wait.createToken({ timeout: "7d" });
244    await notifyEditor({ draftId: draft.id, token: token.id });
245 
246    const decision = await wait.forToken<{ approved: boolean; notes?: string }>(
247      token.id
248    );
249 
250    if (decision.approved) {
251      return await publish(draft);
252    }
253    return await applyFeedback(draft, decision.notes);
254  },
255});
256```
257 
258editor เปิด UI ตรวจสอบร่าง คลิกอนุมัติและ backend ของคุณทำให้ token เสร็จสมบูรณ์ task ดำเนินการต่อจากที่ค้างไว้ - แม้ว่าจะผ่านไปหลายชั่วโมงหรือหลายวัน
259 
260## Lifecycle Hooks
261 
262คุณสามารถแนบ `init`, `onStart`, `onSuccess` และ `onFailure` กับ task หรือทั่วโลกใน `trigger.config.ts` ใช้สำหรับ tracing, error reporting และ setup ที่ใช้ร่วมกัน
263 
264```typescript
265// trigger.config.ts
266export default defineConfig({
267  // ...
268  init: async () => {
269    Sentry.init({ dsn: process.env.SENTRY_DSN });
270  },
271  onFailure: async ({ error, ctx }) => {
272    Sentry.captureException(error, {
273      tags: { taskId: ctx.task.id, runId: ctx.run.id },
274    });
275  },
276});
277```
278 
279`init` รันหนึ่งครั้งต่อ worker container ที่ boot ไม่ใช่ต่อ run ดังนั้นจึงเป็นที่ที่เหมาะสมในการตั้งค่า clients และ pools
280 
281## Realtime ใน Frontend
282 
283Trigger.dev เผยแพร่การเปลี่ยนแปลงสถานะ run - status, metadata, output - ผ่าน streaming API React hooks สมัครรับ stream นั้นและ re-render โดยอัตโนมัติ
284 
285```typescript
286// trigger/process-video.ts
287import { task, metadata } from "@trigger.dev/sdk";
288 
289export const processVideo = task({
290  id: "process-video",
291  run: async (payload: { videoId: string }) => {
292    metadata.set("stage", "transcoding");
293    await transcode(payload.videoId);
294 
295    metadata.set("stage", "thumbnails");
296    await generateThumbnails(payload.videoId);
297 
298    metadata.set("stage", "uploading");
299    const url = await uploadToCDN(payload.videoId);
300 
301    return { url };
302  },
303});
304```
305 
306```tsx
307// components/VideoStatus.tsx
308"use client";
309import { useRealtimeRun } from "@trigger.dev/react-hooks";
310import type { processVideo } from "@/trigger/process-video";
311 
312export function VideoStatus({
313  runId,
314  publicAccessToken,
315}: {
316  runId: string;
317  publicAccessToken: string;
318}) {
319  const { run, error } = useRealtimeRun<typeof processVideo>(runId, {
320    accessToken: publicAccessToken,
321  });
322 
323  if (error) return <p>Error: {error.message}</p>;
324  if (!run) return <p>Loading...</p>;
325 
326  return (
327    <div>
328      <p>Status: {run.status}</p>
329      <p>Stage: {String(run.metadata?.stage ?? "queued")}</p>
330      {run.output?.url && <video src={run.output.url} controls />}
331    </div>
332  );
333}
334```
335 
336คุณสร้าง public access token ฝั่งเซิร์ฟเวอร์ที่กำหนดขอบเขตให้กับ run เฉพาะและส่งให้กับ client hook จัดการ auth, การเชื่อมต่อใหม่และการอัปเดตเพิ่มเติม
337 
338สำหรับ trigger-and-subscribe ในขั้นตอนเดียว:
339 
340```tsx
341import { useRealtimeTaskTrigger } from "@trigger.dev/react-hooks";
342 
343const { submit, run, isLoading } = useRealtimeTaskTrigger<typeof processVideo>(
344  "process-video",
345  { accessToken: publicAccessToken }
346);
347 
348<button onClick={() => submit({ videoId })} disabled={isLoading}>
349  Process video
350</button>;
351```
352 
353## AI Agents และ Streaming
354 
355Trigger.dev กลายเป็น runtime ยอดนิยมสำหรับ AI agents เนื่องจาก primitives เดียวกัน - การประมวลผลที่ทนทาน, retries, waits, real-time metadata, human-in-the-loop - คือสิ่งที่ agents ต้องการ คุณ stream tokens จาก model provider เข้าสู่ `metadata` ในขณะที่ run กำลังเกิดขึ้น frontend แสดงผลแบบสด และ run อยู่รอดผ่าน tool calls ที่ยาวนานโดยไม่เผา timeout serverless
356 
357```typescript
358import { task, metadata } from "@trigger.dev/sdk";
359import { streamText } from "ai";
360import { anthropic } from "@ai-sdk/anthropic";
361 
362export const researchAgent = task({
363  id: "research-agent",
364  maxDuration: 1800,
365  run: async (payload: { question: string }) => {
366    const result = streamText({
367      model: anthropic("claude-opus-4-7"),
368      system: "You are a research assistant. Use the web.",
369      prompt: payload.question,
370      tools: { webSearch },
371    });
372 
373    let fullText = "";
374    for await (const chunk of result.textStream) {
375      fullText += chunk;
376      metadata.set("partial", fullText);
377    }
378 
379    return { answer: fullText, usage: await result.usage };
380  },
381});
382```
383 
384frontend ใช้ `useRealtimeRun` และอ่าน `run.metadata.partial` เพื่อแสดง response แบบ streaming ในวิธีเดียวกับที่คุณจะแสดง chat completion - ยกเว้นว่าอันนี้อยู่รอดจาก reload หน้าเต็ม
385 
386## Deploying
387 
388Deploys คอมไพล์ tasks ของคุณเป็น bundle ที่มีเวอร์ชัน สร้าง container และสลับการรับส่งข้อมูลแบบ atomic Old in-flight runs ยังคงใช้เวอร์ชันก่อนหน้า
389 
390```bash
391npx trigger.dev@latest deploy --env prod
392```
393 
394ใน CI โดยปกติคุณเชื่อมต่อสิ่งนี้กับ workflow เดียวกันที่จัดส่งแอปของคุณ:
395 
396```yaml
397# .github/workflows/deploy.yml
398- name: Deploy Trigger.dev
399  env:
400    TRIGGER_ACCESS_TOKEN: ${{ secrets.TRIGGER_ACCESS_TOKEN }}
401  run: npx trigger.dev@latest deploy --env prod
402```
403 
404สำหรับ environment preview ส่ง `--env preview --branch ${{ github.head_ref }}` และ Trigger.dev สร้างสภาพแวดล้อมที่แยกต่อ branch สะท้อนวิธีที่ Vercel จัดการ preview deployments
405 
406## Self-Hosting vs Cloud
407 
408Trigger.dev เป็นโอเพ่นซอร์สภายใต้ใบอนุญาต Apache 2.0 คุณสามารถ self-host บนแพลตฟอร์ม container ใดๆ (Docker Compose, Kubernetes, Fly.io) หรือใช้ cloud ที่จัดการที่ trigger.dev
409 
410| ด้าน | Cloud | Self-hosted |
411|--------|-------|-------------|
412| **Setup** | ลงทะเบียน รัน `init` | รัน docker-compose หรือ Helm chart |
413| **Scaling** | อัตโนมัติ | ความรับผิดชอบของคุณ |
414| **Pricing** | ต่อ run + ต่อ compute | ค่า infra เท่านั้น |
415| **Compliance** | SOC 2 | สิ่งที่สภาพแวดล้อมของคุณให้ |
416| **เหมาะสำหรับ** | ทีมส่วนใหญ่ | data residency เข้มงวด, infra ที่กำหนดเอง |
417 
418SDK และ CLI เหมือนกันระหว่างโหมด - คุณเปลี่ยน profile flag และชี้ไปที่ instance ของคุณเอง
419 
420## Best Practices
421 
422### 1. รักษา payloads ให้เล็กและ serializable ได้
423 
424ส่ง IDs และการอ้างอิง ไม่ใช่ objects เต็ม ดึงข้อมูลภายใน task สิ่งนี้ช่วยให้ queue เล็ก payloads ถูกในการ log และให้คุณเปลี่ยนแหล่งข้อมูลโดยไม่ต้อง re-trigger
425 
426### 2. Idempotency keys ในทุกการเรียกภายนอก
427 
428รวม `idempotencyKey` บน trigger ของ task กับ idempotency keys บน vendor APIs (Stripe, OpenAI, ฯลฯ) Retries จะปลอดภัย end-to-end
429 
430### 3. ใช้ `triggerAndWait` สำหรับการประสาน ไม่ใช่ `Promise.all` ของ triggers
431 
432parent ที่เรียก `triggerAndWait` รวบรวม tasks ลูกอย่างทนทาน parent ที่ trigger และแก้ไขทันทีจะสูญเสียความสามารถในการสังเกตของ chain
433 
434### 4. Tag runs
435 
436เพิ่ม `tags` ให้กับ triggers (`tags: ["user:123", "feature:onboarding"]`) เพื่อให้คุณสามารถกรอง dashboard และ management API ตามมิติทางธุรกิจ
437 
438### 5. รักษา `init` ให้ idempotent
439 
440มันรันทุก cold start หลีกเลี่ยง migrations หรือ side effects แบบ one-shot ที่นั่น
441 
442## บทสรุป
443 
444Trigger.dev ลบประเภทของงานที่เคยต้องสร้างระบบ job จากศูนย์ คุณเขียน async TypeScript เรียกใช้จากที่ไหนก็ได้และแพลตฟอร์มให้คุณการประมวลผลที่ทนทาน การกำหนดเวลา queues, retries, การอัปเดตแบบ real-time และรูปแบบ human-in-the-loop ออกจากกล่อง
445 
446พื้นผิวเดียวกันที่ขับเคลื่อน cron กลางคืนคือพื้นผิวที่ขับเคลื่อน AI agent หลายขั้นตอนที่ stream ไปยัง frontend และหยุดชั่วคราวสำหรับการตรวจสอบ การบรรจบกันนั้นคือสิ่งที่ทำให้ framework ควรค่าแก่การมองอย่างจริงจังในปี 2026 ไม่ว่าคุณจะกำลังจัดการ SaaS ที่ต้องการงาน background ที่เชื่อถือได้หรือจัดส่งฟีเจอร์ AI ที่อยู่รอดเหนือ timeout serverless
447 
448> **Checklist เริ่มต้น:**
449>
450> - [x] ลงทะเบียนที่ trigger.dev หรือรัน stack Docker self-hosted
451> - [x] `npx trigger.dev@latest init` ในโปรเจคของคุณ
452> - [x] กำหนด task แรกของคุณด้วย `task({ id, run })`
453> - [x] Trigger จาก API ของคุณและดู run ใน dashboard
454> - [x] เพิ่ม `idempotencyKey` และ `concurrencyKey` สำหรับความปลอดภัยใน production
455> - [x] เชื่อม `useRealtimeRun` เข้ากับ status component
456> - [x] Deploy ด้วย `trigger.dev deploy --env prod` จาก CI
457