decentriq_platform.data_connectors.snowflake.connector
Classes
SnowflakeImportConnector
SnowflakeImportConnector(
name: str,
dcr_id: str,
client: Client,
session: Session,
connector_definition: SnowflakeImportConnectorDefinition,
)
A SnowflakeImportConnector which can import data from Snowflake.
Initialise a SnowflakeImportConnector
.
Parameters:
name
: Name of theSnowflakeImportConnector
.dcr_id
: ID of the DCR the connector is a member of.client
: AClient
object which can be used to perform operations such as uploading data and retrieving computation results.session
: The session with which to communicate with the enclave.connector_definition
: Definition of the Snowflake import connector.
Ancestors (in MRO)
- decentriq_platform.analytics.high_level_node.ComputationNode
- decentriq_platform.analytics.high_level_node.HighLevelNode
- abc.ABC
SnowflakeImportConnectorDefinition
SnowflakeImportConnectorDefinition(
name: str,
warehouse_name: str,
database_name: str,
schema_name: str,
table_name: str,
stage_name: str,
credentials_dependency: str,
)
Helper class that provides a standard way to create an ABC using inheritance.
Initialise a SnowflakeImportConnectorDefinition
.
This class is used in order to construct SnowflakeImportConnectors.
Parameters:
name
: Name of theSnowflakeImportConnectorDefinition
.warehouse_name
: Name of the warehouse to be used.database_name
: Name of the database to be used.schema_name
: Name of the schema to be used.table_name
: Name of the table where data is imported from.credentials_dependency
: Name of the credentials node.
Ancestors (in MRO)
- decentriq_platform.analytics.node_definitions.NodeDefinition
- abc.ABC Instance variables
required_workers
:
build
def build(
self,
dcr_id: str,
node_definition: NodeDefinition,
client: Client,
session: Session,
) ‑> SnowflakeImportConnector
Construct a SnowflakeImportConnector from the Node Definition.
Parameters:
dcr_id
: ID of the DCR the node is a member of.node_definition
: Definition of the Import Connector Node.client
: AClient
object which can be used to perform operations such as uploading data and retrieving computation results.session
: The session with which to communicate with the enclave.