Skip to main content

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 the SnowflakeImportConnector.
  • dcr_id: ID of the DCR the connector is a member of.
  • client: A Client 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 the SnowflakeImportConnectorDefinition.
  • 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: A Client 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.