Create app.py

app.py

@@ -0,0 +1,66 @@
+from fastapi import FastAPI, UploadFile, File, Form, HTTPException
+from fastapi.responses import StreamingResponse
+import subprocess
+import io
+import os
+from typing import Optional
+
+app = FastAPI(title="FFmpeg API for n8n")
+
+@app.get("/")
+async def health_check():
+    return {"status": "online", "service": "FFmpeg Image Processor"}
+
+@app.post("/process")
+async def process_image(
+    file: Optional[UploadFile] = File(None),
+    url: Optional[str] = Form(None),
+    options: Optional[str] = Form("-vf scale=800:-1") # 默认缩小到800宽
+):
+    """
+    支持两种输入方式：
+    1. file: 上传二进制图片文件
+    2. url: 远程图片地址
+    """
+    input_source = ""
+    input_data = None
+
+    if file:
+        input_data = await file.read()
+        input_source = "pipe:0"
+    elif url:
+        input_source = url
+    else:
+        raise HTTPException(status_code=400, detail="需提供 file 或 url 参数")
+
+    # 构建命令
+    # 默认输出为 .jpg 格式，你可以根据需要调整
+    command = [
+        'ffmpeg',
+        '-i', input_source,
+    ]
+    
+    # 解析 options 参数并加入命令
+    if options:
+        command.extend(options.split())
+    
+    # 强制输出为图像流
+    command.extend(['-f', 'image2', 'pipe:1'])
+
+    try:
+        process = subprocess.Popen(
+            command,
+            stdin=subprocess.PIPE if input_data else None,
+            stdout=subprocess.PIPE,
+            stderr=subprocess.PIPE
+        )
+        
+        out, err = process.communicate(input=input_data)
+
+        if process.returncode != 0:
+            return {"error": err.decode()}
+
+        return StreamingResponse(io.BytesIO(out), media_type="image/jpeg")
+
+    except Exception as e:
+        raise HTTPException(status_code=500, detail=str(e))