RedshiftIntegration Objects

class RedshiftIntegration(GraiIntegrationImplementation)

A class for extracting Grai compliant metadata from Redshift


  • connector - The connector responsible for communicating with Redshift.


def __init__(namespace: str,
             source: SourceV1,
             version: Optional[str] = None,
             user: Optional[str] = None,
             password: Optional[str] = None,
             database: Optional[str] = None,
             host: Optional[str] = None,
             port: Optional[Union[str, int]] = None)

Initializes the Redshift integration.


  • 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
  • user - The username to use when connecting to Redshift.
  • password - The password to use when connecting to Redshift.
  • host - The Redshift host address.
  • port - The Redshift port.
  • database - The Redshift database to connect to.


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

Returns a tuple of lists of SourcedNode and SourcedEdge objects


def ready() -> bool

Returns True if the integration is ready to run


def nodes() -> List[SourcedNode]

Returns a list of SourcedNode objects


def edges() -> List[SourcedEdge]

Returns a list of SourcedEdge objects