SnowflakeIntegration Objects

class SnowflakeIntegration(GraiIntegrationImplementation)

A class for extracting Grai compliant metadata from Snowflake

Attributes:

• connector - The connector responsible for communicating with Snowflake.

__init__

def __init__(source: SourceV1,
             version: Optional[str] = None,
             account: Optional[str] = None,
             user: Optional[str] = None,
             password: Optional[str] = None,
             warehouse: Optional[str] = None,
             role: Optional[str] = None,
             database: Optional[str] = None,
             namespace: Optional[str] = None,
             **kwargs)

Initializes the Snowflake integration.

Arguments:

• source - The Grai data source to associate with output from the integration. More information about source objects is available in the grai_schemas library.
• version - The Grai data version to associate with output from the integration
• namespace - The Grai namespace to associate with output from the integration
• account - Snowflake account, the characters in front of .snowflakecomputing.com
• user - The database user
• role - The Snowflake role to use.
• warehouse - The Snowflake warehouse to use.
• database - The Snowflake database to connect to.
• grai_schemas0 - The password to use when connecting to Snowflake.

get_nodes_and_edges

@cache
def get_nodes_and_edges() -> Tuple[List[SourcedNode], List[SourcedEdge]]

Returns a tuple of lists of SourcedNode and SourcedEdge objects

ready

def ready() -> bool

Returns True if the integration is ready to run

nodes

def nodes() -> List[SourcedNode]

Returns a list of SourcedNode objects

edges

def edges() -> List[SourcedEdge]

Returns a list of SourcedEdge objects