Databases

bash

# Environment Variables
POSTGRES_URL=postgresql://user:password@host:5432/database
POSTGRES_SCHEMA=clinical_data

python

# Configure PostgreSQL connector
postgres_connector = client.connectors.create(
    name="PostgreSQL Clinical Data",
    source_type="database", 
    config={
        "connection_string": "postgresql://user:pass@localhost:5432/clinical_db",
        "schema": "public",
        "auth_type": "connection_string"
    },
    functions=[
        "query_patient_data",
        "extract_study_results", 
        "validate_data_integrity"
    ]
)

# Use PostgreSQL data in pipeline
pipeline = client.pipelines.create(
    name="Clinical Data Analysis",
    agent_ids=["data-extractor", "statistical-analyzer"],
    connector_id=postgres_connector.id,
    parameters={
        "query": "SELECT * FROM clinical_trials WHERE status = 'completed'"
    }
)

python

# RDS PostgreSQL template
rds_connector = client.connectors.create_from_template(
    template="aws_rds_postgresql",
    name="RDS Clinical Database",
    config={
        "rds_endpoint": "clinical-db.cluster-xyz.us-east-1.rds.amazonaws.com",
        "database": "clinical_data",
        "username": "clinical_user",
        "password": "secure_password",
        "port": 5432
    }
)

bash

# MongoDB Configuration
MONGODB_URI=mongodb://user:password@host:27017/database
MONGODB_DATABASE=clinical_documents

python

# Configure MongoDB connector
mongo_connector = client.connectors.create(
    name="MongoDB Document Store",
    source_type="database",
    config={
        "connection_uri": "mongodb://user:pass@localhost:27017/docs_db",
        "database": "clinical_documents",
        "auth_type": "uri"
    },
    functions=[
        "query_documents",
        "extract_metadata",
        "aggregate_collections"
    ]
)

# MongoDB template for common setups
mongo_template = client.connectors.create_from_template(
    template="mongodb_atlas",
    name="Atlas Clinical Collections",
    config={
        "cluster_url": "mongodb+srv://cluster.mongodb.net/",
        "database": "clinical_data",
        "username": "db_user",
        "password": "db_password"
    }
)