Trino assets app

✦TL;DR

Learn how to crawl Trino assets and publish them to Atlan for discovery.

||

|Connect

The Trino assets app crawls Trino catalogs, schemas, tables, views, and columns and publishes them to Atlan. Build it with the AtlanTrino builder.

Creating an app creates a new connection

Each create mints a new connection and new assets. To re-crawl, re-run the existing workflow (see Re-run an existing app).

Trino supports two authentication methods: basic (username/password) and JWT.

Basic authentication

Python

Trino crawling with basic auth

from pyatlan.client.atlan import AtlanClient
from pyatlan.model.apps import AtlanTrino

client = AtlanClient()

response = (
    AtlanTrino(client)
    .basic( # (1)
        username="atlan_user", # (2)
        password="••••••", # (3)
        enable_tls_https=True, # (4)
        disable_ssl_verification=False, # (5)
        host="trino.example.com", # (6)
    )
    .connection(
        name="production-trino",
        admin_roles=[client.role_cache.get_id_for_name("$admin")],
    )
    .include_metadata({"my_catalog": ["public"]}) # (7)
    .run(name="trino-prod")
)
print(response.slug, response.run_id)

1. Step 1—Credential. Username/password auth; the secret is vaulted.
2. Required. Username.
3. Required. Password.
4. Required. Enable TLS/HTTPS for the connection.
5. Required. Whether to disable SSL certificate verification.
6. Required. The Trino host. The port (port=) is optional.
7. Catalogs/schemas to crawl, as {catalog: [schema, ...]}.

JWT authentication

Python

Trino crawling with a JWT

(
    AtlanTrino(client)
    .jwt(
        jwt_token="eyJ...", # (1)
        enable_tls_https=True, # (2)
        disable_ssl_verification=False, # (3)
        host="trino.example.com",
    )
    .connection(name="production-trino", admin_roles=[...])
    .run(name="trino-prod")
)

1. Required. The JWT token.
2. Required. Enable TLS/HTTPS.
3. Required. Whether to disable SSL verification. port is optional.

Configuration options

All metadata options are optional:

Python

Trino metadata configuration

(
    AtlanTrino(client)
    .basic(username="atlan_user", password="••••••", enable_tls_https=True,
           disable_ssl_verification=False, host="...")
    .connection(name="production-trino", admin_roles=[...])
    .include_metadata({"my_catalog": ["public"]}) # (1)
    .exclude_metadata({"my_catalog": ["staging"]}) # (2)
    .run(name="trino-prod")
)

1. Catalogs/schemas to include, as {catalog: [schema, ...]}.
2. Catalogs/schemas to exclude.