create_recipe_job async ¶

async def create_recipe_job(
    self,
    name: "capo_databrew.types.job_name.JobName",
    role_arn: "capo_databrew.types.arn.Arn",
    *,
    config_overrides: Optional[AsyncDataBrewClientConfig] = None,
    dataset_name: Optional["capo_databrew.types.dataset_name.DatasetName"] = None,
    encryption_key_arn: Optional[
        "capo_databrew.types.encryption_key_arn.EncryptionKeyArn"
    ] = None,
    encryption_mode: Optional[
        "capo_databrew.types.encryption_mode.EncryptionMode"
    ] = None,
    log_subscription: Optional[
        "capo_databrew.types.log_subscription.LogSubscription"
    ] = None,
    max_capacity: Optional["capo_databrew.types.max_capacity.MaxCapacity"] = None,
    max_retries: Optional["capo_databrew.types.max_retries.MaxRetries"] = None,
    outputs: Optional["capo_databrew.types.output_list.OutputList"] = None,
    data_catalog_outputs: Optional[
        "capo_databrew.types.data_catalog_output_list.DataCatalogOutputList"
    ] = None,
    database_outputs: Optional[
        "capo_databrew.types.database_output_list.DatabaseOutputList"
    ] = None,
    project_name: Optional["capo_databrew.types.project_name.ProjectName"] = None,
    recipe_reference: Optional[
        "capo_databrew.types.recipe_reference.RecipeReference"
    ] = None,
    tags: Optional["capo_databrew.types.tag_map.TagMap"] = None,
    timeout: Optional["capo_databrew.types.timeout.Timeout"] = None,
) -> "capo_databrew.types.create_recipe_job_response.CreateRecipeJobResponse":
    """<p>Creates a new job to transform input data, using steps defined in an existing Glue DataBrew recipe</p>

    Args:
        dataset_name: <p>The name of the dataset that this job processes.</p>
        encryption_key_arn: <p>The Amazon Resource Name (ARN) of an encryption key that is used to protect the job.</p>
        encryption_mode: <p>The encryption mode for the job, which can be one of the following:</p> <ul> <li> <p> <code>SSE-KMS</code> - Server-side encryption with keys managed by KMS.</p> </li> <li> <p> <code>SSE-S3</code> - Server-side encryption with keys managed by Amazon S3.</p> </li> </ul>
        name: <p>A unique name for the job. Valid characters are alphanumeric (A-Z, a-z, 0-9), hyphen (-), period (.), and space.</p>
        log_subscription: <p>Enables or disables Amazon CloudWatch logging for the job. If logging is enabled, CloudWatch writes one log stream for each job run.</p>
        max_capacity: <p>The maximum number of nodes that DataBrew can consume when the job processes data.</p>
        max_retries: <p>The maximum number of times to retry the job after a job run fails.</p>
        outputs: <p>One or more artifacts that represent the output from running the job.</p>
        data_catalog_outputs: <p>One or more artifacts that represent the Glue Data Catalog output from running the job.</p>
        database_outputs: <p>Represents a list of JDBC database output objects which defines the output destination for a DataBrew recipe job to write to. </p>
        project_name: <p>Either the name of an existing project, or a combination of a recipe and a dataset to associate with the recipe.</p>
        role_arn: <p>The Amazon Resource Name (ARN) of the Identity and Access Management (IAM) role to be assumed when DataBrew runs the job.</p>
        tags: <p>Metadata tags to apply to this job.</p>
        timeout: <p>The job's timeout in minutes. A job that attempts to run longer than this timeout period ends with a status of <code>TIMEOUT</code>.</p>

    Raises:
        capo_databrew.errors.access_denied_exception.AccessDeniedException: <p>Access to the specified resource was denied.</p>
        capo_databrew.errors.conflict_exception.ConflictException: <p>Updating or deleting a resource can cause an inconsistent state.</p>
        capo_databrew.errors.resource_not_found_exception.ResourceNotFoundException: <p>One or more resources can't be found.</p>
        capo_databrew.errors.service_quota_exceeded_exception.ServiceQuotaExceededException: <p>A service quota is exceeded.</p>
        capo_databrew.errors.validation_exception.ValidationException: <p>The input parameters for this request failed validation.</p>
        capo_databrew.errors.UnknownServiceError: The service returned an error code this client does not model.
    """

    async def _handler(
        req: "AsyncOperationRequest[capo_databrew.types.create_recipe_job_request.CreateRecipeJobRequest]",
    ) -> AsyncOperationResponse[
        "capo_databrew.types.create_recipe_job_response.CreateRecipeJobResponse"
    ]:
        import capo_databrew._operations.aws_glue_data_brew.create_recipe_job

        (
            output,
            http_response,
        ) = await capo_databrew._operations.aws_glue_data_brew.create_recipe_job.async_create_recipe_job(
            req.options, req.input
        )
        return AsyncOperationResponse(output=output, response=http_response)

    interceptors_, options_ = self.operation_options(
        config_overrides, OperationLogging("CreateRecipeJob")
    )
    input_: capo_databrew.types.create_recipe_job_request.CreateRecipeJobRequest = {
        "name": name,
        "role_arn": role_arn,
    }
    if dataset_name is not None:
        input_["dataset_name"] = dataset_name
    if encryption_key_arn is not None:
        input_["encryption_key_arn"] = encryption_key_arn
    if encryption_mode is not None:
        input_["encryption_mode"] = encryption_mode
    if log_subscription is not None:
        input_["log_subscription"] = log_subscription
    if max_capacity is not None:
        input_["max_capacity"] = max_capacity
    if max_retries is not None:
        input_["max_retries"] = max_retries
    if outputs is not None:
        input_["outputs"] = outputs
    if data_catalog_outputs is not None:
        input_["data_catalog_outputs"] = data_catalog_outputs
    if database_outputs is not None:
        input_["database_outputs"] = database_outputs
    if project_name is not None:
        input_["project_name"] = project_name
    if recipe_reference is not None:
        input_["recipe_reference"] = recipe_reference
    if tags is not None:
        input_["tags"] = tags
    if timeout is not None:
        input_["timeout"] = timeout

    response = await aexecute_pipeline(
        AsyncOperationRequest(input=input_, options=options_),
        handler=_handler,
        interceptors=list(interceptors_),
    )
    await response.response.aclose()
    return response.output