DataQualityJobDefinition class

Provides a SageMaker AI data quality job definition resource.

Example Usage

Basic usage:

import * as pulumi from "@pulumi/pulumi";
import * as aws from "@pulumi/aws";

const test = new aws.sagemaker.DataQualityJobDefinition("test", {
    dataQualityAppSpecification: {
        imageUri: monitor.registryPath,
    },
    dataQualityJobInput: {
        endpointInput: {
            endpointName: myEndpoint.name,
        },
    },
    dataQualityJobOutputConfig: {
        monitoringOutputs: {
            s3Output: {
                s3Uri: `https://${myBucket.bucketRegionalDomainName}/output`,
            },
        },
    },
    jobResources: {
        clusterConfig: {
            instanceCount: 1,
            instanceType: "ml.t3.medium",
            volumeSizeInGb: 20,
        },
    },
    name: "my-data-quality-job-definition",
    roleArn: myRole.arn,
});

import pulumi
import pulumi_aws as aws

test = aws.sagemaker.DataQualityJobDefinition("test",
    data_quality_app_specification={
        "image_uri": monitor["registryPath"],
    },
    data_quality_job_input={
        "endpoint_input": {
            "endpoint_name": my_endpoint["name"],
        },
    },
    data_quality_job_output_config={
        "monitoring_outputs": {
            "s3_output": {
                "s3_uri": f"https://{my_bucket['bucketRegionalDomainName']}/output",
            },
        },
    },
    job_resources={
        "cluster_config": {
            "instance_count": 1,
            "instance_type": "ml.t3.medium",
            "volume_size_in_gb": 20,
        },
    },
    name="my-data-quality-job-definition",
    role_arn=my_role["arn"])

using System.Collections.Generic;
using System.Linq;
using Pulumi;
using Aws = Pulumi.Aws;

return await Deployment.RunAsync(() =>
{
    var test = new Aws.Sagemaker.DataQualityJobDefinition("test", new()
    {
        DataQualityAppSpecification = new Aws.Sagemaker.Inputs.DataQualityJobDefinitionDataQualityAppSpecificationArgs
        {
            ImageUri = monitor.RegistryPath,
        },
        DataQualityJobInput = new Aws.Sagemaker.Inputs.DataQualityJobDefinitionDataQualityJobInputArgs
        {
            EndpointInput = new Aws.Sagemaker.Inputs.DataQualityJobDefinitionDataQualityJobInputEndpointInputArgs
            {
                EndpointName = myEndpoint.Name,
            },
        },
        DataQualityJobOutputConfig = new Aws.Sagemaker.Inputs.DataQualityJobDefinitionDataQualityJobOutputConfigArgs
        {
            MonitoringOutputs = new Aws.Sagemaker.Inputs.DataQualityJobDefinitionDataQualityJobOutputConfigMonitoringOutputsArgs
            {
                S3Output = new Aws.Sagemaker.Inputs.DataQualityJobDefinitionDataQualityJobOutputConfigMonitoringOutputsS3OutputArgs
                {
                    S3Uri = $"https://{myBucket.BucketRegionalDomainName}/output",
                },
            },
        },
        JobResources = new Aws.Sagemaker.Inputs.DataQualityJobDefinitionJobResourcesArgs
        {
            ClusterConfig = new Aws.Sagemaker.Inputs.DataQualityJobDefinitionJobResourcesClusterConfigArgs
            {
                InstanceCount = 1,
                InstanceType = "ml.t3.medium",
                VolumeSizeInGb = 20,
            },
        },
        Name = "my-data-quality-job-definition",
        RoleArn = myRole.Arn,
    });

});

package main

import (
	"github.com/pulumi/pulumi-aws/sdk/v7/go/aws/sagemaker"
	"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
)

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := sagemaker.NewDataQualityJobDefinition(ctx, "test", &sagemaker.DataQualityJobDefinitionArgs{
			DataQualityAppSpecification: &sagemaker.DataQualityJobDefinitionDataQualityAppSpecificationArgs{
				ImageUri: pulumi.Any(monitor.RegistryPath),
			},
			DataQualityJobInput: &sagemaker.DataQualityJobDefinitionDataQualityJobInputArgs{
				EndpointInput: &sagemaker.DataQualityJobDefinitionDataQualityJobInputEndpointInputArgs{
					EndpointName: pulumi.Any(myEndpoint.Name),
				},
			},
			DataQualityJobOutputConfig: &sagemaker.DataQualityJobDefinitionDataQualityJobOutputConfigArgs{
				MonitoringOutputs: &sagemaker.DataQualityJobDefinitionDataQualityJobOutputConfigMonitoringOutputsArgs{
					S3Output: sagemaker.DataQualityJobDefinitionDataQualityJobOutputConfigMonitoringOutputsS3OutputArgs{
						S3Uri: pulumi.Sprintf("https://%v/output", myBucket.BucketRegionalDomainName),
					},
				},
			},
			JobResources: &sagemaker.DataQualityJobDefinitionJobResourcesArgs{
				ClusterConfig: &sagemaker.DataQualityJobDefinitionJobResourcesClusterConfigArgs{
					InstanceCount:  pulumi.Int(1),
					InstanceType:   pulumi.String("ml.t3.medium"),
					VolumeSizeInGb: pulumi.Int(20),
				},
			},
			Name:    pulumi.String("my-data-quality-job-definition"),
			RoleArn: pulumi.Any(myRole.Arn),
		})
		if err != nil {
			return err
		}
		return nil
	})
}

pulumi {
  required_providers {
    aws = {
      source = "pulumi/aws"
    }
  }
}

resource "aws_sagemaker_dataqualityjobdefinition" "test" {
  data_quality_app_specification = {
    image_uri = monitor.registryPath
  }
  data_quality_job_input = {
    endpoint_input = {
      endpoint_name = myEndpoint.name
    }
  }
  data_quality_job_output_config = {
    monitoring_outputs = {
      s3_output = {
        s3_uri ="https://${myBucket.bucketRegionalDomainName}/output"
      }
    }
  }
  job_resources = {
    cluster_config = {
      instance_count    = 1
      instance_type     = "ml.t3.medium"
      volume_size_in_gb = 20
    }
  }
  name     = "my-data-quality-job-definition"
  role_arn = myRole.arn
}

package generated_program;

import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.aws.sagemaker.DataQualityJobDefinition;
import com.pulumi.aws.sagemaker.DataQualityJobDefinitionArgs;
import com.pulumi.aws.sagemaker.inputs.DataQualityJobDefinitionDataQualityAppSpecificationArgs;
import com.pulumi.aws.sagemaker.inputs.DataQualityJobDefinitionDataQualityJobInputArgs;
import com.pulumi.aws.sagemaker.inputs.DataQualityJobDefinitionDataQualityJobInputEndpointInputArgs;
import com.pulumi.aws.sagemaker.inputs.DataQualityJobDefinitionDataQualityJobOutputConfigArgs;
import com.pulumi.aws.sagemaker.inputs.DataQualityJobDefinitionDataQualityJobOutputConfigMonitoringOutputsArgs;
import com.pulumi.aws.sagemaker.inputs.DataQualityJobDefinitionDataQualityJobOutputConfigMonitoringOutputsS3OutputArgs;
import com.pulumi.aws.sagemaker.inputs.DataQualityJobDefinitionJobResourcesArgs;
import com.pulumi.aws.sagemaker.inputs.DataQualityJobDefinitionJobResourcesClusterConfigArgs;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.Map;
import java.io.File;
import java.nio.file.Files;
import java.nio.file.Paths;

public class App {
    public static void main(String[] args) {
        Pulumi.run(App::stack);
    }

    public static void stack(Context ctx) {
        var test = new DataQualityJobDefinition("test", DataQualityJobDefinitionArgs.builder()
            .dataQualityAppSpecification(DataQualityJobDefinitionDataQualityAppSpecificationArgs.builder()
                .imageUri(monitor.registryPath())
                .build())
            .dataQualityJobInput(DataQualityJobDefinitionDataQualityJobInputArgs.builder()
                .endpointInput(DataQualityJobDefinitionDataQualityJobInputEndpointInputArgs.builder()
                    .endpointName(myEndpoint.name())
                    .build())
                .build())
            .dataQualityJobOutputConfig(DataQualityJobDefinitionDataQualityJobOutputConfigArgs.builder()
                .monitoringOutputs(DataQualityJobDefinitionDataQualityJobOutputConfigMonitoringOutputsArgs.builder()
                    .s3Output(DataQualityJobDefinitionDataQualityJobOutputConfigMonitoringOutputsS3OutputArgs.builder()
                        .s3Uri(String.format("https://%s/output", myBucket.bucketRegionalDomainName()))
                        .build())
                    .build())
                .build())
            .jobResources(DataQualityJobDefinitionJobResourcesArgs.builder()
                .clusterConfig(DataQualityJobDefinitionJobResourcesClusterConfigArgs.builder()
                    .instanceCount(1)
                    .instanceType("ml.t3.medium")
                    .volumeSizeInGb(20)
                    .build())
                .build())
            .name("my-data-quality-job-definition")
            .roleArn(myRole.arn())
            .build());

    }
}

resources:
  test:
    type: aws:sagemaker:DataQualityJobDefinition
    properties:
      dataQualityAppSpecification:
        imageUri: ${monitor.registryPath}
      dataQualityJobInput:
        endpointInput:
          endpointName: ${myEndpoint.name}
      dataQualityJobOutputConfig:
        monitoringOutputs:
          s3Output:
            s3Uri: https://${myBucket.bucketRegionalDomainName}/output
      jobResources:
        clusterConfig:
          instanceCount: 1
          instanceType: ml.t3.medium
          volumeSizeInGb: 20
      name: my-data-quality-job-definition
      roleArn: ${myRole.arn}

Import

Using pulumi import, import data quality job definitions using the name. For example:

$ pulumi import aws:sagemaker/dataQualityJobDefinition:DataQualityJobDefinition test_data_quality_job_definition data-quality-job-definition-foo