validio_sdk.resource.sources module

class validio_sdk.resource.sources.AwsAthenaSource(*, name: str, credential: AwsAthenaCredential, catalog: str, database: str, table: str, schedule: str | None, display_name: str | None = None, owner: str | None = None, ignore_changes: bool = False, recreate_on_change: bool = False, jtd_schema: dict | None = None, description: str | None = None, tags: list[Tag] | None = None, priority: IncidentGroupPriority | None = None)

class validio_sdk.resource.sources.AwsKinesisSource(*, name: str, credential: AwsCredential, region: str, stream_name: str, display_name: str | None = None, owner: str | None = None, ignore_changes: bool = False, recreate_on_change: bool = False, jtd_schema: dict | None = None, message_format: StreamingMessageFormat | None = None, description: str | None = None, tags: list[Tag] | None = None, priority: IncidentGroupPriority | None = None)

class validio_sdk.resource.sources.AwsRedshiftSource(*, name: str, credential: PostgreSqlCredential | AwsRedshiftCredential, database: str | None, table: str, schedule: str | None, schema: str, display_name: str | None = None, owner: str | None = None, ignore_changes: bool = False, recreate_on_change: bool = False, jtd_schema: dict | None = None, description: str | None = None, tags: list[Tag] | None = None, priority: IncidentGroupPriority | None = None)

class validio_sdk.resource.sources.AzureSynapseSource(*, name: str, credential: AzureSynapseCredential, database: str, table: str, schedule: str | None, schema: str, display_name: str | None = None, owner: str | None = None, ignore_changes: bool = False, recreate_on_change: bool = False, jtd_schema: dict | None = None, description: str | None = None, tags: list[Tag] | None = None, priority: IncidentGroupPriority | None = None)

class validio_sdk.resource.sources.ClickHouseSource(*, name: str, credential: ClickHouseCredential, database: str, table: str, schedule: str | None, display_name: str | None = None, owner: str | None = None, ignore_changes: bool = False, recreate_on_change: bool = False, jtd_schema: dict | None = None, description: str | None = None, tags: list[Tag] | None = None, priority: IncidentGroupPriority | None = None)

class validio_sdk.resource.sources.DatabricksSource(*, name: str, credential: DatabricksCredential, catalog: str, table: str, schedule: str | None, schema: str, display_name: str | None = None, owner: str | None = None, ignore_changes: bool = False, recreate_on_change: bool = False, http_path: str | None = None, jtd_schema: dict | None = None, description: str | None = None, tags: list[Tag] | None = None, priority: IncidentGroupPriority | None = None)

class validio_sdk.resource.sources.DbtModelRunSource(*, name: str, credential: GcpCredential, project_name: str, job_name: str, schedule: str | None = '0/15 * * * *', display_name: str | None = None, owner: str | None = None, ignore_changes: bool = False, recreate_on_change: bool = False, jtd_schema: dict | None = None, description: str | None = None, tags: list[Tag] | None = None, priority: IncidentGroupPriority | None = None)

class validio_sdk.resource.sources.DbtSource(*, name: str, credential: GcpCredential, project_name: str, job_name: str, schedule: str | None = '0/15 * * * *', display_name: str | None = None, owner: str | None = None, ignore_changes: bool = False, recreate_on_change: bool = False, jtd_schema: dict | None = None, description: str | None = None, tags: list[Tag] | None = None, priority: IncidentGroupPriority | None = None)

class validio_sdk.resource.sources.DbtTestResultSource(*, name: str, credential: GcpCredential, project_name: str, job_name: str, schedule: str | None = '0/15 * * * *', display_name: str | None = None, owner: str | None = None, ignore_changes: bool = False, recreate_on_change: bool = False, jtd_schema: dict | None = None, description: str | None = None, tags: list[Tag] | None = None, priority: IncidentGroupPriority | None = None)

class validio_sdk.resource.sources.DemoSource(*, name: str, credential: DemoCredential, owner: str | None = None, display_name: str | None = None, ignore_changes: bool = False, recreate_on_change: bool = False, jtd_schema: dict | None = None, description: str | None = None, tags: list[Tag] | None = None, priority: IncidentGroupPriority | None = None)

class validio_sdk.resource.sources.GcpBigQuerySource(*, name: str, credential: GcpCredential, project: str, dataset: str, table: str, schedule: str | None, display_name: str | None = None, owner: str | None = None, ignore_changes: bool = False, recreate_on_change: bool = False, description: str | None = None, jtd_schema: dict | None = None, billing_project: str | None = None, tags: list[Tag] | None = None, priority: IncidentGroupPriority | None = None)

class validio_sdk.resource.sources.GcpPubSubSource(*, name: str, credential: GcpCredential, project: str, subscription_id: str, display_name: str | None = None, owner: str | None = None, ignore_changes: bool = False, recreate_on_change: bool = False, jtd_schema: dict | None = None, message_format: StreamingMessageFormat | None = None, description: str | None = None, tags: list[Tag] | None = None, priority: IncidentGroupPriority | None = None)

class validio_sdk.resource.sources.IbmDb2Source(name: str, credential: IbmDb2Credential, database: str, schema: str, table: str, schedule: str | None, display_name: str | None = None, owner: str | None = None, ignore_changes: bool = False, recreate_on_change: bool = False, jtd_schema: dict | None = None, description: str | None = None, tags: list[Tag] | None = None, priority: IncidentGroupPriority | None = None)

class validio_sdk.resource.sources.KafkaSource(*, name: str, credential: KafkaSslCredential | KafkaSaslSslPlainCredential, topic: str, display_name: str | None = None, owner: str | None = None, ignore_changes: bool = False, recreate_on_change: bool = False, jtd_schema: dict | None = None, message_format: StreamingMessageFormat | None = None, description: str | None = None, tags: list[Tag] | None = None, priority: IncidentGroupPriority | None = None)

class validio_sdk.resource.sources.MsSqlServerSource(*, name: str, credential: MsSqlServerCredential, database: str, schema: str, table: str, schedule: str | None, display_name: str | None = None, owner: str | None = None, ignore_changes: bool = False, recreate_on_change: bool = False, jtd_schema: dict | None = None, description: str | None = None, tags: list[Tag] | None = None, priority: IncidentGroupPriority | None = None)

class validio_sdk.resource.sources.OpenEdgeSource(*, name: str, credential: OpenEdgeCredential, schema: str, table: str, schedule: str | None, display_name: str | None = None, owner: str | None = None, ignore_changes: bool = False, recreate_on_change: bool = False, jtd_schema: dict | None = None, description: str | None = None, tags: list[Tag] | None = None, priority: IncidentGroupPriority | None = None)

class validio_sdk.resource.sources.OracleSource(*, name: str, credential: OracleCredential, database: str, schema: str, table: str, schedule: str | None, display_name: str | None = None, owner: str | None = None, ignore_changes: bool = False, recreate_on_change: bool = False, jtd_schema: dict | None = None, description: str | None = None, tags: list[Tag] | None = None, priority: IncidentGroupPriority | None = None)

class validio_sdk.resource.sources.PostgreSqlSource(*, name: str, credential: PostgreSqlCredential | AwsRedshiftCredential, database: str | None, table: str, schedule: str | None, schema: str, display_name: str | None = None, owner: str | None = None, ignore_changes: bool = False, recreate_on_change: bool = False, jtd_schema: dict | None = None, description: str | None = None, tags: list[Tag] | None = None, priority: IncidentGroupPriority | None = None)

class validio_sdk.resource.sources.PostgresLikeSource(*, name: str, credential: PostgreSqlCredential | AwsRedshiftCredential, database: str | None, table: str, schedule: str | None, schema: str, display_name: str | None = None, owner: str | None = None, ignore_changes: bool = False, recreate_on_change: bool = False, jtd_schema: dict | None = None, description: str | None = None, tags: list[Tag] | None = None, priority: IncidentGroupPriority | None = None)

class validio_sdk.resource.sources.SapIqSource(*, name: str, credential: SapIqCredential, database: str, schema: str, table: str, schedule: str | None, display_name: str | None = None, owner: str | None = None, ignore_changes: bool = False, recreate_on_change: bool = False, jtd_schema: dict | None = None, description: str | None = None, tags: list[Tag] | None = None, priority: IncidentGroupPriority | None = None)

class validio_sdk.resource.sources.SnowflakeSource(*, name: str, credential: SnowflakeCredential, database: str, table: str, schedule: str | None, schema: str, display_name: str | None = None, owner: str | None = None, ignore_changes: bool = False, recreate_on_change: bool = False, warehouse: str | None = None, role: str | None = None, jtd_schema: dict | None = None, description: str | None = None, tags: list[Tag] | None = None, priority: IncidentGroupPriority | None = None)

class validio_sdk.resource.sources.Source(name: str, credential: Credential, display_name: str | None, owner: str | None = None, ignore_changes: bool = False, recreate_on_change: bool = False, jtd_schema: dict | None = None, description: str | None = None, tags: list[Tag] | None = None, priority: IncidentGroupPriority | None = None)

resource_class_name() → str

class validio_sdk.resource.sources.SqlSource(*, name: str, credential: AzureSynapseCredential | AwsAthenaCredential | AwsRedshiftCredential | ClickHouseCredential | DatabricksCredential | GcpCredential | IbmDb2Credential | PostgreSqlCredential | OracleCredential | OpenEdgeCredential | SapIqCredential | SnowflakeCredential | TeradataCredential, sql_query: str, schedule: str | None, display_name: str | None = None, owner: str | None = None, ignore_changes: bool = False, recreate_on_change: bool = False, jtd_schema: dict | None = None, description: str | None = None, tags: list[Tag] | None = None, priority: IncidentGroupPriority | None = None)

class validio_sdk.resource.sources.StreamSource(name: str, credential: Credential, display_name: str | None, owner: str | None = None, ignore_changes: bool = False, recreate_on_change: bool = False, jtd_schema: dict | None = None, message_format: StreamingMessageFormat | None = None, description: str | None = None, tags: list[Tag] | None = None, priority: IncidentGroupPriority | None = None)

class validio_sdk.resource.sources.StreamingMessageFormat(format: StreamingSourceMessageFormat | None = StreamingSourceMessageFormat.JSON, schema: str | None = None)

class validio_sdk.resource.sources.StreamingSourceMessageFormat(*values)

AVRO = 'AVRO'

JSON = 'JSON'

PROTOBUF = 'PROTOBUF'

class validio_sdk.resource.sources.TeradataSource(*, name: str, credential: TeradataCredential, database: str, table: str, schedule: str | None, display_name: str | None = None, owner: str | None = None, ignore_changes: bool = False, recreate_on_change: bool = False, jtd_schema: dict | None = None, description: str | None = None, tags: list[Tag] | None = None, priority: IncidentGroupPriority | None = None)

class validio_sdk.resource.sources.WarehouseSource(name: str, credential: Credential, display_name: str | None, owner: str | None = None, ignore_changes: bool = False, recreate_on_change: bool = False, jtd_schema: dict | None = None, description: str | None = None, tags: list[Tag] | None = None, priority: IncidentGroupPriority | None = None)