Добро пожаловать в Kruma Data Contracts¶

Что такое Data Contracts?¶

Контракт данных — это формальное соглашение между издателем данных и потребителем, которое определяет:

Зачем это нужно?¶

Проблемы без контрактов¶

Решение: Data Contracts¶

Архитектура¶

graph LR
    A[Producer<br/>1C, CRM] -->|Avro| B[API Gateway<br/>mTLS]
    B -->|201 Created| A
    B --> C[Kafka .raw]
    C --> D[Quality<br/>Validator]
    D --> E[Kafka .prod]
    D --> F[Kafka .dlq]
    F --> G[Alerts]
    E --> H[Consumers<br/>BI, ML]

    style B fill:#4CAF50,color:#fff
    style D fill:#FF9800,color:#fff
    style F fill:#F44336,color:#fff

Ключевой принцип¶

Для кого эта документация?¶

Быстрый старт¶

1. Создайте контракт¶

spec_version: "1.0.0"
contract_version: "1.0.0"

metadata:
  name: "orders"
  namespace: "sales"
  display_name: "Заказы клиентов"

  owner:
    team: "sales-integration"
    email: "sales-data@company.ru"

schema:
  file: "./schema.avsc"
  format: "avro"

quality_rules:
  file: "./quality_rules.yml"

2. Определите правила качества¶

version: "1.0"

rules:
  - name: "order_id_not_null"
    field: "order_id"
    type: "not_null"
    severity: "error"

  - name: "total_amount_positive"
    field: "total_amount"
    type: "range"
    min: 0
    severity: "error"

3. Отправьте данные¶

import requests
import avro.io

# Сериализация в Avro
avro_payload = serialize_to_avro(record, schema)

# Отправка в API Gateway
response = requests.post(
    "https://gateway.kruma.io/api/1.0/sales.orders",
    data=avro_payload,
    headers={
        "Content-Type": "application/avro",
        "version": "1.0.0",
        "batch": "1",
    },
    cert=("sales.orders.crt", "sales.orders.key"),
)
# Получаем 201 Created - издатель свободен!

Что нового¶

Технологии¶

Контакты¶

Нужна помощь с внедрением?

• Email: hello@kruma.io
• Telegram: @kruma_io
• GitLab: git.kruma.io