Como integrar dados jurídicos via REST API: tutorial completo com Python e Node.js

POST https://requests.prod.judit.io/requests

# Header obrigatório:
Authorization: Bearer SUA_API_KEY_AQUI
Content-Type: application/json

import requests
import os
import json

# Carrega a API Key da variável de ambiente
API_KEY = os.getenv("JUDIT_API_KEY")
ENDPOINT = "https://requests.prod.judit.io/requests"

def consultar_processos(cpf_ou_cnpj: str) -> dict:
    """Consulta processos judiciais por CPF ou CNPJ."""

    # Headers da requisição
    headers = {
        "Authorization": f"Bearer {API_KEY}",
        "Content-Type": "application/json"
    }

    # Body da requisição
    payload = {
        "search_type": "cpf_cnpj",   # tipo de busca
        "search_key": cpf_ou_cnpj,    # valor a pesquisar
        "response_type": "lawsuits"    # tipo de resposta desejada
    }

    try:
        response = requests.post(
            ENDPOINT,
            headers=headers,
            json=payload,
            timeout=30
        )
        response.raise_for_status()  # Lança exceção se status != 2xx
        return response.json()

    except requests.exceptions.HTTPError as e:
        print(f"Erro HTTP: {e.response.status_code} - {e.response.text}")
    except requests.exceptions.Timeout:
        print("Timeout: a requisição demorou mais de 30 segundos")
    except requests.exceptions.RequestException as e:
        print(f"Erro na requisição: {e}")

    return None


# Exemplo de uso
if __name__ == "__main__":
    resultado = consultar_processos("12345678901")  # CPF sem pontuação

    if resultado:
        print(f"Request ID: {resultado.get('request_id')}")
        print(json.dumps(resultado, indent=2, ensure_ascii=False))

// response_type: "lawsuits"
// → Todos os processos judiciais (cíveis, trabalhistas, criminais, federais)

// response_type: "entity"
// → Dados cadastrais (Receita Federal, situação, sócios)

// response_type: "warrant"
// → Mandados de prisão (consulta ao BNMP)

// response_type: "criminal_execution"
// → Execuções criminais (para compliance e background check)

# Consulta por número CNJ
payload = {
    "search_type": "lawsuit_cnj",
    "search_key": "0001234-56.2023.8.26.0100",
    "response_type": "lawsuit"
}

# Consulta por número OAB (monitora carteira de advogado)
payload_oab = {
    "search_type": "oab",
    "search_key": "SP123456",
    "response_type": "lawsuits"
}

import time
from functools import wraps

def retry_with_backoff(max_retries=3, base_delay=1.0):
    """Decorator para retry automático com backoff exponencial."""
    def decorator(func):
        @wraps(func)
        def wrapper(*args, **kwargs):
            for attempt in range(max_retries):
                try:
                    return func(*args, **kwargs)
                except requests.exceptions.HTTPError as e:
                    # 429 = rate limit → espera antes de tentar novamente
                    if e.response.status_code == 429:
                        delay = base_delay * (2 ** attempt)
                        print(f"Rate limit atingido. Aguardando {delay}s...")
                        time.sleep(delay)
                    else:
                        raise
            raise Exception("Máximo de tentativas atingido")
        return wrapper
    return decorator

# Aplique o decorator na sua função de consulta:
@retry_with_backoff(max_retries=3)
def consultar_com_retry(cpf_cnpj):
    return consultar_processos(cpf_cnpj)