API для интеграции: запись на входе, JSON и PDF на выходе

Примеры кода

Полный цикл: отправить запись, дождаться готовности, забрать JSON и PDF. Ответы проверены на рабочем сервере.

curl

export BASE=https://kardiopilot.ru/api/v1
export TOKEN=kp_ваш_токен

# 0. проверить токен и лимиты
curl -H "Authorization: Bearer $TOKEN" "$BASE/me"

# 1. отправить запись (.npz, .csv, .edf или PDF кардиографа GE MUSE)
curl -H "Authorization: Bearer $TOKEN" -F "file=@ecg.npz" "$BASE/jobs"
# {"id":"xs7wVdOR…","status":"queued","links":{"self":…,"result":…,"pdf":…}}

# частоту и единицы CSV система определяет сама; укажите, только если она ошиблась:
curl -H "Authorization: Bearer $TOKEN" -F "file=@ecg.csv" -F fs=500 -F units=mV "$BASE/jobs"

# данные пациента — по желанию. Без них отчёт пишет «не указано» и берёт строгие пороги:
curl -H "Authorization: Bearer $TOKEN" -F "file=@ecg.csv"      -F "name=Пациент №42" -F sex=male -F age=40 -F height=182 -F weight=88 -F "bp=125/80"      "$BASE/jobs"

# 2. статус — повторять раз в 1–2 секунды до completed или failed
curl -H "Authorization: Bearer $TOKEN" "$BASE/jobs/$JOB"

# 3. заключение в JSON и PDF-отчёт
curl -H "Authorization: Bearer $TOKEN" "$BASE/jobs/$JOB/result"
curl -H "Authorization: Bearer $TOKEN" "$BASE/jobs/$JOB/pdf" -o report.pdf

Python (requests)

import time
import requests

BASE = "https://kardiopilot.ru/api/v1"
HEADERS = {"Authorization": "Bearer kp_ваш_токен"}


def analyse(path: str, patient: dict | None = None) -> dict:
    # 1. Отправить запись. Частота и единицы CSV определяются по файлу;
    #    передайте fs и units, только если определение ошиблось.
    #    patient: sex, age, height, weight, bp, name — всё по желанию.
    with open(path, "rb") as f:
        response = requests.post(f"{BASE}/jobs", headers=HEADERS, files={"file": f},
                                 data=patient or {}, timeout=60)
    response.raise_for_status()
    job_id = response.json()["id"]

    # 2. Дождаться готовности: обычно 5–10 секунд.
    while True:
        status = requests.get(f"{BASE}/jobs/{job_id}", headers=HEADERS, timeout=30).json()
        if status["status"] == "completed":
            break
        if status["status"] == "failed":
            raise RuntimeError(f"Анализ не выполнен: {status['error']}")
        time.sleep(1.5)

    # 3. JSON-заключение.
    result = requests.get(f"{BASE}/jobs/{job_id}/result", headers=HEADERS, timeout=30).json()

    # 4. PDF-отчёт на 9 страниц.
    pdf = requests.get(f"{BASE}/jobs/{job_id}/pdf", headers=HEADERS, timeout=60)
    pdf.raise_for_status()
    with open(f"report-{job_id[:8]}.pdf", "wb") as out:
        out.write(pdf.content)
    return result


result = analyse("ecg.npz")
print(result["traffic_light"], result["urgency"])
for diagnosis in result["top_diagnoses"]:
    print(f"{diagnosis['name_ru']}: {diagnosis['score']:.2f}")

JavaScript (Node.js)

// Node.js 18+ (встроенные fetch, FormData и Blob)
import { readFile, writeFile } from "node:fs/promises";

const BASE = "https://kardiopilot.ru/api/v1";
const headers = { Authorization: "Bearer kp_ваш_токен" };
const sleep = (ms) => new Promise((resolve) => setTimeout(resolve, ms));

const form = new FormData();
form.append("file", new Blob([await readFile("ecg.csv")]), "ecg.csv");
// частота и единицы CSV определяются по файлу — эти поля нужны только для правки:
// form.append("fs", "500"); form.append("units", "mV");
form.append("sex", "male");   // данные пациента — по желанию
form.append("age", "40");

const created = await fetch(`${BASE}/jobs`, { method: "POST", headers, body: form });
if (!created.ok) throw new Error((await created.json()).detail);
const { id } = await created.json();

let status;
do {
  await sleep(1500);
  status = await (await fetch(`${BASE}/jobs/${id}`, { headers })).json();
} while (!["completed", "failed"].includes(status.status));
if (status.status === "failed") throw new Error(status.error);

const result = await (await fetch(`${BASE}/jobs/${id}/result`, { headers })).json();
console.log(result.traffic_light, result.primary_diagnosis?.name_ru);

const pdf = await fetch(`${BASE}/jobs/${id}/pdf`, { headers });
await writeFile("report.pdf", Buffer.from(await pdf.arrayBuffer()));

Опрос пациента

С параметром interview=true задание после анализа ждёт ответов. Варианты ответа: yes, probably_yes, unsure, probably_no, no. Ответы меняют оценку срочности и печатаются в PDF; баллы ЭКГ опрос не меняет. Брошенный опрос закрывается автоматически через 30 минут.

ANSWERS = ("yes", "probably_yes", "unsure", "probably_no", "no")

with open("ecg.npz", "rb") as f:
    job_id = requests.post(f"{BASE}/jobs", headers=HEADERS, files={"file": f},
                           data={"interview": "true"}, timeout=60).json()["id"]

while True:
    status = requests.get(f"{BASE}/jobs/{job_id}", headers=HEADERS, timeout=30).json()["status"]
    if status in ("completed", "failed"):
        break
    if status != "awaiting_interview":      # queued, processing, queued_answer, queued_report
        time.sleep(1)
        continue
    state = requests.get(f"{BASE}/jobs/{job_id}/interview", headers=HEADERS, timeout=30).json()
    question = state["question"]
    # question["safety"] == True — вопрос безопасности (боль в груди, одышка, обморок)
    answer = ask_patient(question["text"])  # ваш интерфейс: одно из ANSWERS
    requests.post(f"{BASE}/jobs/{job_id}/answers", headers=HEADERS, timeout=30,
                  json={"question_id": question["id"], "answer": answer})

# Завершить опрос досрочно (отчёт построится по уже данным ответам):
# requests.post(f"{BASE}/jobs/{job_id}/finish", headers=HEADERS)

Формат записи

До 10 МиБ на файл, длительность 2–60 секунд (для 6 и 6 + 1 отведений — от 10 секунд, подробнее). Фотографии и сканы бумажной ленты, PDF и произвольные архивы не принимаются. Не передавайте ФИО и другие персональные данные: для анализа нужен только сигнал.

ЭКГ из 6 и 6 + 1 отведений

Те же вызовы и тот же формат. Режим определяется по сигналу: если записаны только I и II, это 6 отведений; если ещё одно грудное — 6 + 1. Незаписанные отведения передаются нулями. Рекомендуемая частота 500 Гц, длина записи 20 секунд, не меньше 10: анализ идёт по самому чистому отрезку 10 секунд. Что умеет этот режим →

{
  "status": "repeat",
  "reason": "contact",
  "electrode": "LA",
  "attempt": 1, "max_attempts": 3, "lead_mode": "6L+V3",
  "screen_text": "Нет контакта с левой рукой. Положите левую ладонь на датчик целиком и не отрывайте её.",
  "analysis_window_s": [4.0, 14.0],
  "chest_declared": "V3",
  "chest_candidates": ["V4"]
}

В chest_candidates — позиция грудного электрода, которую система признала по сигналу и по которой идёт анализ (заявленная или соседняя). Отчёт для 6 и 6 + 1 отведений — 8 страниц.