grove.connectors.snowflake package¶

Snowflake connectors for Grove.

Submodules¶

grove.connectors.snowflake.common module¶

Snowflake connector for Grove.

class grove.connectors.snowflake.common.SnowflakeConnector(config: ConnectorConfig, context: Dict[str, str])[source]¶

Bases: BaseConnector

Defines common fields used across all Snowflake connector types.

This has been done to reduce the amount of boilerplate and duplication across the different Snowflake connectors in Grove.

property account: str¶

Fetches the Snowflake account name from the configuration.

Returns:: The “account” portion of the connector’s configuration.

property batch_size: int¶

Fetches the batch size from the configuration.

This is used to control the maximum number of records which will be retrieved before they are flushed to the output handler.

The default is 1000.

Returns:: The “batch_size” portion of the connector’s configuration.

property database: str | None¶

Fetches the optional database name from the configuration.

The default is “ADMIN”.

Returns:: The “database” portion of the connector’s configuration.

property passphrase: str | None¶

Fetches the optional private key passphrase from the configuration.

Returns:: The “passphrase” portion of the connector’s configuration.

property role: str | None¶

Fetches the optional Snowflake role name from the configuration.

Returns:: The “role” portion of the connector’s configuration.

property schema: str | None¶

Fetches the optional schema name from the configuration.

The default is “SNOWFLAKE”.

Returns:: The “schema” portion of the connector’s configuration.

property warehouse: str | None¶

Fetches the optional Snowflake warehouse name from the configuration.

Returns:: The “warehouse” portion of the connector’s configuration.

grove.connectors.snowflake.login_history module¶

Snowflake login history connector for Grove.

class grove.connectors.snowflake.login_history.Connector(config: ConnectorConfig, context: Dict[str, str])[source]¶

Bases: SnowflakeConnector

LOG_ORDER = 'CHRONOLOGICAL'¶

NAME = 'snowflake_login_history'¶

POINTER_PATH = 'EVENT_TIMESTAMP'¶

collect()[source]¶: Collects login history records from Snowflake.

grove.connectors.snowflake.query_history module¶

Snowflake query history connector for Grove.

class grove.connectors.snowflake.query_history.Connector(config: ConnectorConfig, context: Dict[str, str])[source]¶

Bases: SnowflakeConnector

LOG_ORDER = 'CHRONOLOGICAL'¶

NAME = 'snowflake_query_history'¶

POINTER_PATH = 'START_TIME'¶

collect()[source]¶: Collects query history records from Snowflake.

grove.connectors.snowflake.session_history module¶

Snowflake session history connector for Grove.

class grove.connectors.snowflake.session_history.Connector(config: ConnectorConfig, context: Dict[str, str])[source]¶

Bases: SnowflakeConnector

LOG_ORDER = 'CHRONOLOGICAL'¶

NAME = 'snowflake_session_history'¶

POINTER_PATH = 'CREATED_ON'¶

collect()[source]¶: Collects session history records from Snowflake.