Casar os dois cadastros

-- ERRADO: colide no dia em que você atender a segunda conta.
UNIQUE (pictor_device_id)

-- CERTO: a chave é o par.
UNIQUE (pictor_conta_id, pictor_device_id)

-- TAMBÉM CERTO, e mais simples se você não precisa do serial:
UNIQUE (pictor_device_uuid)

Conta (uma chave = uma conta)
└── Cliente          ← o condomínio, a loja: quem paga o serviço
    └── Local Monitorado  ← o endereço vigiado
        └── Câmera

{
  "device_id": "EXEMPLO-0001",
  "device_uuid": "0b8f1c22-…",
  "name": "Guarita - entrada",
  "status": "active",
  "transmitting": "yes",
  "monitored_site_id": "…", "monitored_site_name": "Cond. Alvorada — Portaria",
  "client_id": "…",          "client_name": "Cond. Alvorada",
  "tax_id": "12.345.678/0001-90",
  "central_account_ref": "4021"
}

import httpx

def sincronizar(conta_id: str, chave: str, base: str, desde: str | None) -> str:
    """`desde` é o `synced_at` que você guardou da última vez. `None` na primeira."""
    cabecalho = {"Authorization": f"Bearer {chave}"}
    with httpx.Client(base_url=base, headers=cabecalho, timeout=30) as http:
        offset = 0
        while True:
            params = {"limit": 500, "offset": offset}
            if desde:
                params["updated_since"] = desde
            r = http.get("/api/devices", params=params)
            r.raise_for_status()
            corpo = r.json()
            for camera in corpo["items"]:
                upsert(
                    conta_id=conta_id,
                    uuid=camera["device_uuid"],       # a chave
                    serial=camera["device_id"],       # o rótulo
                    nome=camera["name"],
                    cliente_id=camera.get("client_id"),
                    local_id=camera.get("monitored_site_id"),
                )
            # `removed` só vem quando você pede `updated_since`.
            for morta in corpo.get("removed") or []:
                marcar_inativa(conta_id, morta["device_uuid"], morta["deleted_at"])
            offset += len(corpo["items"])
            if offset >= corpo["total"]:
                break
    # Guarde o instante ANTES da chamada, não depois: o que mudar durante a
    # leitura entra na próxima janela em vez de cair no vão entre as duas.
    return agora_iso()

curl -s -H "Authorization: Bearer $PICTOR_KEY" \
  "$PICTOR_API/api/devices?client_id=$CLIENTE&limit=500"

corpo = r.json()
if not corpo["transmitting_witness_fresh"]:
    # Medição fora da validade: "0 câmeras sem imagem" aqui significa
    # "sem medição", e não "está tudo bem". Não abra ocorrência, e não
    # feche as que estão abertas.
    return

janela = corpo["transmitting_window_seconds"]   # a janela usada, em segundos
medido_em = corpo["transmitting_witness_last_success_at"]