pip install fastpii-connect

from fastpii_connect import FastPIIClient

client = FastPIIClient(
    api_key="fpk_your_api_key",
    base_url="https://api.fastpii.com",  # default
    timeout=30,          # request timeout in seconds
    max_retries=2,      # retries for 408, 429, 502, 503, 504 errors
)

from fastpii_connect import AsyncFastPII

async with AsyncFastPII(api_key="fpk_your_api_key") as client:
    result = await client.detect("My rodné číslo is 900101/1234")
    print(result.entities)

async with AsyncFastPII(api_key="fpk_your_api_key") as client:
    response = await client.gateway.chat.completions(
        model="gpt-4o",
        messages=[{"role": "user", "content": "Hello!"}],
    )

result = client.detect(
    text="My rodné číslo is 900101/1234",
    country="cz",           # optional: ISO country code
    language="cs",          # optional: language hint
    privacy_preset="balanced",  # optional: "conservative", "balanced", "aggressive"
)

result = client.protect(
    text="My rodné číslo is 900101/1234",
    mode="replace",         # "replace", "mask", "hash", "tokenize"
    country="cz",           # optional
    language="cs",          # optional
    privacy_preset="aggressive",  # optional
)

result = client.validate(
    value="900101/1234",
    entity_type="rodne_cislo",
    country="cz",   # optional
)

detectors = client.list_detectors(country="CZ")  # optional country filter
for d in detectors.detectors:
    print(f"{d.name} ({d.region}): {d.description}")

result = client.detect_batch(
    texts=["Text one", "Text two", "Text three"],
    country="cz",  # optional
)
print(f"Total entities: {result.total_entities}")

result = client.protect_batch(
    texts=["Text one", "Text two"],
    mode="mask",    # optional, default "replace"
    country="cz",   # optional
)
print(f"Total entities: {result.total_entities}")

health = client.health()
print(f"Status: {health.status}, Version: {health.version}")

session = client.create_session()
result1 = session.detect("My rodné číslo is 900101/1234")
print(session.countries)       # ["CZ"]

result2 = session.detect("My PESEL is 90010112345")
print(session.countries)       # ["CZ", "PL"]
print(session.message_count)  # 2

# Non-streaming
response = client.gateway.chat.completions(
    model="gpt-4o",
    messages=[{"role": "user", "content": "Hello!"}],
)

# Streaming
for event in client.gateway.chat.stream(
    model="gpt-4o",
    messages=[{"role": "user", "content": "Hello!"}],
):
    if hasattr(event, "content"):
        print(event.content, end="")

client.close()

from fastpii_connect.errors import (
    FastPIIError,
    AuthenticationError,
    RateLimitError,
    QuotaExceededError,
    ValidationError,
    ServerError,
    ConnectionError,
    TimeoutError,
)

try:
    result = client.detect("text")
except AuthenticationError:
    print("Invalid API key")
except RateLimitError as e:
    print(f"Rate limited. Retry after {e.retry_after} seconds")
except QuotaExceededError:
    print("Monthly quota exceeded")
except ValidationError as e:
    print(f"Request error: {e.message} (status {e.status_code})")
except ServerError:
    print("Server error")
except ConnectionError as e:
    print(f"Connection failed: {e.message}")
except FastPIIError as e:
    print(f"FastPII error: {e.message}")