MODULE REFERENCE

local_fs

anomx.data.sources.local_fs

Filesystem-backed CSV connector.

LocalFSConnector

LocalFSConnector

Bases: BaseConnector

Read and write CSV files from the local filesystem.

Members

readmethod
read(config: dict[str, Any]) -> pd.DataFrame
Signature parameters
ParameterTypeDefault
configdict[str, Any]required

Returns pd.DataFrame

writemethod
write(data: Any, config: dict[str, Any]) -> None
Signature parameters
ParameterTypeDefault
dataAnyrequired
configdict[str, Any]required

Returns None

streammethod
stream(config: dict[str, Any]) -> Iterable[dict[str, Any]]
Signature parameters
ParameterTypeDefault
configdict[str, Any]required

Returns Iterable[dict[str, Any]]

schemamethod
schema() -> dict[str, Any]

Returns dict[str, Any]