QueryExecutionContext

class aws_cdk.aws_stepfunctions_tasks.QueryExecutionContext(*, catalog_name=None, database_name=None)

Bases: object

Database and data catalog context in which the query execution occurs.

Parameters:

  • catalog_name (Optional[str]) – Name of catalog used in query execution. Default: - No catalog

  • database_name (Optional[str]) – Name of database used in query execution. Default: - No database

See:

https://docs.aws.amazon.com/athena/latest/APIReference/API_QueryExecutionContext.html

ExampleMetadata:

infused

Example:

start_query_execution_job = tasks.AthenaStartQueryExecution(self, "Start Athena Query",
    query_string=sfn.JsonPath.string_at("$.queryString"),
    query_execution_context=tasks.QueryExecutionContext(
        database_name="mydatabase"
    ),
    result_configuration=tasks.ResultConfiguration(
        encryption_configuration=tasks.EncryptionConfiguration(
            encryption_option=tasks.EncryptionOption.S3_MANAGED
        ),
        output_location=s3.Location(
            bucket_name="amzn-s3-demo-bucket",
            object_key="folder"
        )
    ),
    execution_parameters=["param1", "param2"]
)

Attributes

catalog_name

Name of catalog used in query execution.

Default:

  • No catalog

database_name

Name of database used in query execution.

Default:

  • No database