Unsere Pipeline.
Dein Produkt.

// Als ESM speichern (z. B. clip.mjs) und mit `node clip.mjs` laufen lassen.
import { writeFileSync } from "node:fs";

const API = "https://www.lucflow.de/api/v1";
const headers = { Authorization: `Bearer ${process.env.LUCFLOW_API_KEY}` };

// 1. Job anlegen
const create = await fetch(`${API}/jobs`, {
  method: "POST",
  headers: { ...headers, "Content-Type": "application/json" },
  body: JSON.stringify({
    source_url: "https://www.youtube.com/watch?v=…",
    options: { format: "9:16", content_type: "gaming" },
  }),
});
const { id } = await create.json();

// 2. Pollen, bis der Job fertig ist
let job;
do {
  await new Promise((r) => setTimeout(r, 30_000));
  job = await (await fetch(`${API}/jobs/${id}`, { headers })).json();
  console.log(job.status, `${job.progress}%`);
} while (job.status === "queued" || job.status === "processing");
if (job.status !== "done") throw new Error(job.error ?? "failed");

// 3. Ersten Clip speichern
const clip = job.clips[0];
const res = await fetch(clip.download_url, { headers });
const buf = Buffer.from(await res.arrayBuffer());
writeFileSync(`${clip.id}.mp4`, buf);

import os, time, requests

API = "https://www.lucflow.de/api/v1"
headers = {"Authorization": f"Bearer {os.environ['LUCFLOW_API_KEY']}"}

# 1. Job anlegen
r = requests.post(f"{API}/jobs", headers=headers, json={
    "source_url": "https://www.youtube.com/watch?v=…",
    "options": {"format": "9:16", "content_type": "gaming"},
})
job_id = r.json()["id"]

# 2. Pollen, bis der Job fertig ist
while True:
    job = requests.get(f"{API}/jobs/{job_id}", headers=headers).json()
    print(job["status"], f'{job["progress"]}%')
    if job["status"] in ("done", "error"):
        break
    time.sleep(30)
if job["status"] != "done":
    raise SystemExit(job.get("error") or "failed")

# 3. Ersten Clip speichern
clip = job["clips"][0]
mp4 = requests.get(clip["download_url"], headers=headers)
open(f'{clip["id"]}.mp4', "wb").write(mp4.content)