Dışa aktarma dosyasını indir

curl --fail-with-body --silent --show-error --include --request GET \
  "${SIPARIS_API_URL:-https://api.siparis.app/v1}/files/fil_1234567890abcdef1234567890abcdef" \
  -H "Authorization: Bearer $SIPARIS_API_KEY"
# 307 ise Location adresini yeni bir curl isteğinde Authorization olmadan açın.
# 200 yanıtı JSONL/CSV dosyasıdır; büyük dosyalar için --output kullanın.

import os
import shutil
import sys
from urllib.request import Request, build_opener, HTTPRedirectHandler
from urllib.error import HTTPError

class NoRedirect(HTTPRedirectHandler):
    def redirect_request(self, req, fp, code, msg, headers, newurl):
        return None

base = os.environ.get("SIPARIS_API_URL", "https://api.siparis.app/v1")
request = Request(base + "/files/fil_1234567890abcdef1234567890abcdef", headers={
    "Authorization": "Bearer " + os.environ["SIPARIS_API_KEY"]
})
opener = build_opener(NoRedirect)
try:
    response = opener.open(request, timeout=30)
except HTTPError as error:
    if error.code != 307 or not error.headers.get("Location"):
        raise
    # İmzalı hedefe API anahtarı gönderilmez; ikinci yönlendirme izlenmez.
    response = opener.open(Request(error.headers["Location"]), timeout=30)
with response:
    shutil.copyfileobj(response, sys.stdout.buffer)
# Dosyaya yazmak için: python indir.py > siparis-export.jsonl

// Node.js 22+; dosyayı belleğe almak yerine stdout'a aktarır.
import { Readable } from "node:stream";
import { pipeline } from "node:stream/promises";
import type { ReadableStream } from "node:stream/web";

const base = process.env.SIPARIS_API_URL ?? "https://api.siparis.app/v1";
if (!process.env.SIPARIS_API_KEY) throw new Error("SIPARIS_API_KEY gerekli");
let response = await fetch(base + "/files/fil_1234567890abcdef1234567890abcdef", {
  headers: { Authorization: `Bearer ${process.env.SIPARIS_API_KEY}` },
  redirect: "manual", signal: AbortSignal.timeout(60_000),
});
if (response.status === 307) {
  const location = response.headers.get("Location");
  if (!location) throw new Error("İndirme adresi eksik");
  // Ayrı istek: Authorization başlığı eklenmez.
  response = await fetch(location, { redirect: "error", credentials: "omit", signal: AbortSignal.timeout(60_000) });
}
if (!response.ok || !response.body) throw new Error(`İndirme başarısız: ${response.status}`);
await pipeline(Readable.fromWeb(response.body as ReadableStream), process.stdout);