MODULE REFERENCE

connector

anomx.data.base.connector

Base connector contract.

BaseConnector

BaseConnector

Bases: ABC

Read and write datasets for component workflows.

readmethod

read(config: dict[str, Any]) -> Any

Read data from a source.

Signature parameters
Parameter	Type	Default
`config`	`dict[str, Any]`	`required`

Returns Any

writemethod

write(data: Any, config: dict[str, Any]) -> None

Write data to a target.

Signature parameters
Parameter	Type	Default
`data`	`Any`	`required`
`config`	`dict[str, Any]`	`required`

Returns None

streammethod

stream(config: dict[str, Any]) -> Iterable[Any]

Stream records from a source.

Signature parameters
Parameter	Type	Default
`config`	`dict[str, Any]`	`required`

Returns Iterable[Any]

schemamethod

schema() -> dict[str, Any]

Return the connector configuration schema.

Returns dict[str, Any]