Skip to main content

decentriq_platform.data_connectors.aws.connector

Classes​

AwsExportConnector​

AwsExportConnector(
    name: str,
    dcr_id: str,
    client: Client,
    session: Session,
    connector_definition: NodeDefinition,
)

An AwsExportConnector which can export data to AWS.

Initialise an AwsExportConnector.

Parameters:

  • name: Name of the AwsExportConnector.
  • 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 AWS export connector.

Ancestors (in MRO)

  • decentriq_platform.analytics.high_level_node.ComputationNode
  • decentriq_platform.analytics.high_level_node.HighLevelNode
  • abc.ABC

AwsExportConnectorDefinition​

AwsExportConnectorDefinition(
    name: str,
    bucket: str,
    region: str,
    credentials_dependency: str,
    node_dependency: ExportNodeDependency,
)

Helper class that provides a standard way to create an ABC using inheritance.

Initialise an AwsExportConnectorDefinition. This class is used in order to construct an AwsExportConnector.

Parameters:

  • name: Name of the AwsExportConnectorDefinition.
  • bucket: The name of the bucket that will store the object.
  • region: The geographic region of the bucket.
  • credentials_dependency: Name of the credentials node.
  • node_dependency: The name of the node who's data will be exported to AWS. This also defines the type of upload (raw, single file in a zip, entire zip contents).

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,
) ‑> AwsExportConnector

Construct an AwsExportConnector from the definition.

Parameters:

  • dcr_id: ID of the DCR the connector is a member of.
  • node_definition: Definition of the Aws export connector.
  • 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.

AwsImportConnector​

AwsImportConnector(
    name: str,
    dcr_id: str,
    client: Client,
    session: Session,
    connector_definition: AwsImportConnectorDefinition,
)

An AwsImportConnector which can import data from AWS.

Initialise an AwsImportConnector.

Parameters:

  • name: Name of the AwsImportConnector.
  • 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 AWS import connector.

Ancestors (in MRO)

  • decentriq_platform.analytics.high_level_node.ComputationNode
  • decentriq_platform.analytics.high_level_node.HighLevelNode
  • abc.ABC

AwsImportConnectorDefinition​

AwsImportConnectorDefinition(
    name: str,
    object_key: str,
    bucket: str,
    region: str,
    credentials_dependency: str,
)

Helper class that provides a standard way to create an ABC using inheritance.

Initialise an AwsImportConnectorDefinition. This class is used in order to construct AwsImportConnectors.

Parameters:

  • name: Name of the AwsImportConnectorDefinition.
  • object_key: Name of the object to be imported.
  • bucket: The name of the bucket where the object will be imported from.
  • region: The geographic region of the bucket.
  • 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,
) ‑> AwsImportConnector

Construct an AwsImportConnector 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.