lib/aws-sdk-glue/client.rb in aws-sdk-glue-1.178.0 vs lib/aws-sdk-glue/client.rb in aws-sdk-glue-1.179.0
- old
+ new
@@ -1969,10 +1969,11 @@
# resp.jobs[0].source_control_details.folder #=> String
# resp.jobs[0].source_control_details.last_commit_id #=> String
# resp.jobs[0].source_control_details.auth_strategy #=> String, one of "PERSONAL_ACCESS_TOKEN", "AWS_SECRETS_MANAGER"
# resp.jobs[0].source_control_details.auth_token #=> String
# resp.jobs[0].maintenance_window #=> String
+ # resp.jobs[0].profile_name #=> String
# resp.jobs_not_found #=> Array
# resp.jobs_not_found[0] #=> String
#
# @see http://docs.aws.amazon.com/goto/WebAPI/glue-2017-03-31/BatchGetJobs AWS API Documentation
#
@@ -2305,10 +2306,11 @@
# resp.workflows[0].last_run.graph.nodes[0].job_details.job_runs[0].notification_property.notify_delay_after #=> Integer
# resp.workflows[0].last_run.graph.nodes[0].job_details.job_runs[0].glue_version #=> String
# resp.workflows[0].last_run.graph.nodes[0].job_details.job_runs[0].dpu_seconds #=> Float
# resp.workflows[0].last_run.graph.nodes[0].job_details.job_runs[0].execution_class #=> String, one of "FLEX", "STANDARD"
# resp.workflows[0].last_run.graph.nodes[0].job_details.job_runs[0].maintenance_window #=> String
+ # resp.workflows[0].last_run.graph.nodes[0].job_details.job_runs[0].profile_name #=> String
# resp.workflows[0].last_run.graph.nodes[0].crawler_details.crawls #=> Array
# resp.workflows[0].last_run.graph.nodes[0].crawler_details.crawls[0].state #=> String, one of "RUNNING", "CANCELLING", "CANCELLED", "SUCCEEDED", "FAILED", "ERROR"
# resp.workflows[0].last_run.graph.nodes[0].crawler_details.crawls[0].started_on #=> Time
# resp.workflows[0].last_run.graph.nodes[0].crawler_details.crawls[0].completed_on #=> Time
# resp.workflows[0].last_run.graph.nodes[0].crawler_details.crawls[0].error_message #=> String
@@ -2375,10 +2377,11 @@
# resp.workflows[0].graph.nodes[0].job_details.job_runs[0].notification_property.notify_delay_after #=> Integer
# resp.workflows[0].graph.nodes[0].job_details.job_runs[0].glue_version #=> String
# resp.workflows[0].graph.nodes[0].job_details.job_runs[0].dpu_seconds #=> Float
# resp.workflows[0].graph.nodes[0].job_details.job_runs[0].execution_class #=> String, one of "FLEX", "STANDARD"
# resp.workflows[0].graph.nodes[0].job_details.job_runs[0].maintenance_window #=> String
+ # resp.workflows[0].graph.nodes[0].job_details.job_runs[0].profile_name #=> String
# resp.workflows[0].graph.nodes[0].crawler_details.crawls #=> Array
# resp.workflows[0].graph.nodes[0].crawler_details.crawls[0].state #=> String, one of "RUNNING", "CANCELLING", "CANCELLED", "SUCCEEDED", "FAILED", "ERROR"
# resp.workflows[0].graph.nodes[0].crawler_details.crawls[0].started_on #=> Time
# resp.workflows[0].graph.nodes[0].crawler_details.crawls[0].completed_on #=> Time
# resp.workflows[0].graph.nodes[0].crawler_details.crawls[0].error_message #=> String
@@ -4513,10 +4516,11 @@
# resp.session.worker_type #=> String, one of "Standard", "G.1X", "G.2X", "G.025X", "G.4X", "G.8X", "Z.2X"
# resp.session.completed_on #=> Time
# resp.session.execution_time #=> Float
# resp.session.dpu_seconds #=> Float
# resp.session.idle_timeout #=> Integer
+ # resp.session.profile_name #=> String
#
# @see http://docs.aws.amazon.com/goto/WebAPI/glue-2017-03-31/CreateSession AWS API Documentation
#
# @overload create_session(params = {})
# @param [Hash] params ({})
@@ -4830,10 +4834,70 @@
def create_trigger(params = {}, options = {})
req = build_request(:create_trigger, params)
req.send_request(options)
end
+ # Creates an Glue usage profile.
+ #
+ # @option params [required, String] :name
+ # The name of the usage profile.
+ #
+ # @option params [String] :description
+ # A description of the usage profile.
+ #
+ # @option params [required, Types::ProfileConfiguration] :configuration
+ # A `ProfileConfiguration` object specifying the job and session values
+ # for the profile.
+ #
+ # @option params [Hash<String,String>] :tags
+ # A list of tags applied to the usage profile.
+ #
+ # @return [Types::CreateUsageProfileResponse] Returns a {Seahorse::Client::Response response} object which responds to the following methods:
+ #
+ # * {Types::CreateUsageProfileResponse#name #name} => String
+ #
+ # @example Request syntax with placeholder values
+ #
+ # resp = client.create_usage_profile({
+ # name: "NameString", # required
+ # description: "DescriptionString",
+ # configuration: { # required
+ # session_configuration: {
+ # "NameString" => {
+ # default_value: "ConfigValueString",
+ # allowed_values: ["ConfigValueString"],
+ # min_value: "ConfigValueString",
+ # max_value: "ConfigValueString",
+ # },
+ # },
+ # job_configuration: {
+ # "NameString" => {
+ # default_value: "ConfigValueString",
+ # allowed_values: ["ConfigValueString"],
+ # min_value: "ConfigValueString",
+ # max_value: "ConfigValueString",
+ # },
+ # },
+ # },
+ # tags: {
+ # "TagKey" => "TagValue",
+ # },
+ # })
+ #
+ # @example Response structure
+ #
+ # resp.name #=> String
+ #
+ # @see http://docs.aws.amazon.com/goto/WebAPI/glue-2017-03-31/CreateUsageProfile AWS API Documentation
+ #
+ # @overload create_usage_profile(params = {})
+ # @param [Hash] params ({})
+ def create_usage_profile(params = {}, options = {})
+ req = build_request(:create_usage_profile, params)
+ req.send_request(options)
+ end
+
# Creates a new function definition in the Data Catalog.
#
# @option params [String] :catalog_id
# The ID of the Data Catalog in which to create the function. If none is
# provided, the Amazon Web Services account ID is used by default.
@@ -5736,10 +5800,32 @@
def delete_trigger(params = {}, options = {})
req = build_request(:delete_trigger, params)
req.send_request(options)
end
+ # Deletes the Glue specified usage profile.
+ #
+ # @option params [required, String] :name
+ # The name of the usage profile to delete.
+ #
+ # @return [Struct] Returns an empty {Seahorse::Client::Response response}.
+ #
+ # @example Request syntax with placeholder values
+ #
+ # resp = client.delete_usage_profile({
+ # name: "NameString", # required
+ # })
+ #
+ # @see http://docs.aws.amazon.com/goto/WebAPI/glue-2017-03-31/DeleteUsageProfile AWS API Documentation
+ #
+ # @overload delete_usage_profile(params = {})
+ # @param [Hash] params ({})
+ def delete_usage_profile(params = {}, options = {})
+ req = build_request(:delete_usage_profile, params)
+ req.send_request(options)
+ end
+
# Deletes an existing function definition from the Data Catalog.
#
# @option params [String] :catalog_id
# The ID of the Data Catalog where the function to be deleted is
# located. If none is supplied, the Amazon Web Services account ID is
@@ -8299,10 +8385,11 @@
# resp.job.source_control_details.folder #=> String
# resp.job.source_control_details.last_commit_id #=> String
# resp.job.source_control_details.auth_strategy #=> String, one of "PERSONAL_ACCESS_TOKEN", "AWS_SECRETS_MANAGER"
# resp.job.source_control_details.auth_token #=> String
# resp.job.maintenance_window #=> String
+ # resp.job.profile_name #=> String
#
# @see http://docs.aws.amazon.com/goto/WebAPI/glue-2017-03-31/GetJob AWS API Documentation
#
# @overload get_job(params = {})
# @param [Hash] params ({})
@@ -8361,11 +8448,12 @@
def get_job_bookmark(params = {}, options = {})
req = build_request(:get_job_bookmark, params)
req.send_request(options)
end
- # Retrieves the metadata for a given job run.
+ # Retrieves the metadata for a given job run. Job run history is
+ # accessible for 90 days for your workflow and job run.
#
# @option params [required, String] :job_name
# Name of the job definition being run.
#
# @option params [required, String] :run_id
@@ -8415,10 +8503,11 @@
# resp.job_run.notification_property.notify_delay_after #=> Integer
# resp.job_run.glue_version #=> String
# resp.job_run.dpu_seconds #=> Float
# resp.job_run.execution_class #=> String, one of "FLEX", "STANDARD"
# resp.job_run.maintenance_window #=> String
+ # resp.job_run.profile_name #=> String
#
# @see http://docs.aws.amazon.com/goto/WebAPI/glue-2017-03-31/GetJobRun AWS API Documentation
#
# @overload get_job_run(params = {})
# @param [Hash] params ({})
@@ -8483,10 +8572,11 @@
# resp.job_runs[0].notification_property.notify_delay_after #=> Integer
# resp.job_runs[0].glue_version #=> String
# resp.job_runs[0].dpu_seconds #=> Float
# resp.job_runs[0].execution_class #=> String, one of "FLEX", "STANDARD"
# resp.job_runs[0].maintenance_window #=> String
+ # resp.job_runs[0].profile_name #=> String
# resp.next_token #=> String
#
# @see http://docs.aws.amazon.com/goto/WebAPI/glue-2017-03-31/GetJobRuns AWS API Documentation
#
# @overload get_job_runs(params = {})
@@ -9402,10 +9492,11 @@
# resp.jobs[0].source_control_details.folder #=> String
# resp.jobs[0].source_control_details.last_commit_id #=> String
# resp.jobs[0].source_control_details.auth_strategy #=> String, one of "PERSONAL_ACCESS_TOKEN", "AWS_SECRETS_MANAGER"
# resp.jobs[0].source_control_details.auth_token #=> String
# resp.jobs[0].maintenance_window #=> String
+ # resp.jobs[0].profile_name #=> String
# resp.next_token #=> String
#
# @see http://docs.aws.amazon.com/goto/WebAPI/glue-2017-03-31/GetJobs AWS API Documentation
#
# @overload get_jobs(params = {})
@@ -10792,10 +10883,11 @@
# resp.session.worker_type #=> String, one of "Standard", "G.1X", "G.2X", "G.025X", "G.4X", "G.8X", "Z.2X"
# resp.session.completed_on #=> Time
# resp.session.execution_time #=> Float
# resp.session.dpu_seconds #=> Float
# resp.session.idle_timeout #=> Integer
+ # resp.session.profile_name #=> String
#
# @see http://docs.aws.amazon.com/goto/WebAPI/glue-2017-03-31/GetSession AWS API Documentation
#
# @overload get_session(params = {})
# @param [Hash] params ({})
@@ -12162,10 +12254,57 @@
def get_unfiltered_table_metadata(params = {}, options = {})
req = build_request(:get_unfiltered_table_metadata, params)
req.send_request(options)
end
+ # Retrieves information about the specified Glue usage profile.
+ #
+ # @option params [required, String] :name
+ # The name of the usage profile to retrieve.
+ #
+ # @return [Types::GetUsageProfileResponse] Returns a {Seahorse::Client::Response response} object which responds to the following methods:
+ #
+ # * {Types::GetUsageProfileResponse#name #name} => String
+ # * {Types::GetUsageProfileResponse#description #description} => String
+ # * {Types::GetUsageProfileResponse#configuration #configuration} => Types::ProfileConfiguration
+ # * {Types::GetUsageProfileResponse#created_on #created_on} => Time
+ # * {Types::GetUsageProfileResponse#last_modified_on #last_modified_on} => Time
+ #
+ # @example Request syntax with placeholder values
+ #
+ # resp = client.get_usage_profile({
+ # name: "NameString", # required
+ # })
+ #
+ # @example Response structure
+ #
+ # resp.name #=> String
+ # resp.description #=> String
+ # resp.configuration.session_configuration #=> Hash
+ # resp.configuration.session_configuration["NameString"].default_value #=> String
+ # resp.configuration.session_configuration["NameString"].allowed_values #=> Array
+ # resp.configuration.session_configuration["NameString"].allowed_values[0] #=> String
+ # resp.configuration.session_configuration["NameString"].min_value #=> String
+ # resp.configuration.session_configuration["NameString"].max_value #=> String
+ # resp.configuration.job_configuration #=> Hash
+ # resp.configuration.job_configuration["NameString"].default_value #=> String
+ # resp.configuration.job_configuration["NameString"].allowed_values #=> Array
+ # resp.configuration.job_configuration["NameString"].allowed_values[0] #=> String
+ # resp.configuration.job_configuration["NameString"].min_value #=> String
+ # resp.configuration.job_configuration["NameString"].max_value #=> String
+ # resp.created_on #=> Time
+ # resp.last_modified_on #=> Time
+ #
+ # @see http://docs.aws.amazon.com/goto/WebAPI/glue-2017-03-31/GetUsageProfile AWS API Documentation
+ #
+ # @overload get_usage_profile(params = {})
+ # @param [Hash] params ({})
+ def get_usage_profile(params = {}, options = {})
+ req = build_request(:get_usage_profile, params)
+ req.send_request(options)
+ end
+
# Retrieves a specified function definition from the Data Catalog.
#
# @option params [String] :catalog_id
# The ID of the Data Catalog where the function to be retrieved is
# located. If none is provided, the Amazon Web Services account ID is
@@ -12375,10 +12514,11 @@
# resp.workflow.last_run.graph.nodes[0].job_details.job_runs[0].notification_property.notify_delay_after #=> Integer
# resp.workflow.last_run.graph.nodes[0].job_details.job_runs[0].glue_version #=> String
# resp.workflow.last_run.graph.nodes[0].job_details.job_runs[0].dpu_seconds #=> Float
# resp.workflow.last_run.graph.nodes[0].job_details.job_runs[0].execution_class #=> String, one of "FLEX", "STANDARD"
# resp.workflow.last_run.graph.nodes[0].job_details.job_runs[0].maintenance_window #=> String
+ # resp.workflow.last_run.graph.nodes[0].job_details.job_runs[0].profile_name #=> String
# resp.workflow.last_run.graph.nodes[0].crawler_details.crawls #=> Array
# resp.workflow.last_run.graph.nodes[0].crawler_details.crawls[0].state #=> String, one of "RUNNING", "CANCELLING", "CANCELLED", "SUCCEEDED", "FAILED", "ERROR"
# resp.workflow.last_run.graph.nodes[0].crawler_details.crawls[0].started_on #=> Time
# resp.workflow.last_run.graph.nodes[0].crawler_details.crawls[0].completed_on #=> Time
# resp.workflow.last_run.graph.nodes[0].crawler_details.crawls[0].error_message #=> String
@@ -12445,10 +12585,11 @@
# resp.workflow.graph.nodes[0].job_details.job_runs[0].notification_property.notify_delay_after #=> Integer
# resp.workflow.graph.nodes[0].job_details.job_runs[0].glue_version #=> String
# resp.workflow.graph.nodes[0].job_details.job_runs[0].dpu_seconds #=> Float
# resp.workflow.graph.nodes[0].job_details.job_runs[0].execution_class #=> String, one of "FLEX", "STANDARD"
# resp.workflow.graph.nodes[0].job_details.job_runs[0].maintenance_window #=> String
+ # resp.workflow.graph.nodes[0].job_details.job_runs[0].profile_name #=> String
# resp.workflow.graph.nodes[0].crawler_details.crawls #=> Array
# resp.workflow.graph.nodes[0].crawler_details.crawls[0].state #=> String, one of "RUNNING", "CANCELLING", "CANCELLED", "SUCCEEDED", "FAILED", "ERROR"
# resp.workflow.graph.nodes[0].crawler_details.crawls[0].started_on #=> Time
# resp.workflow.graph.nodes[0].crawler_details.crawls[0].completed_on #=> Time
# resp.workflow.graph.nodes[0].crawler_details.crawls[0].error_message #=> String
@@ -12468,11 +12609,12 @@
def get_workflow(params = {}, options = {})
req = build_request(:get_workflow, params)
req.send_request(options)
end
- # Retrieves the metadata for a given workflow run.
+ # Retrieves the metadata for a given workflow run. Job run history is
+ # accessible for 90 days for your workflow and job run.
#
# @option params [required, String] :name
# Name of the workflow being run.
#
# @option params [required, String] :run_id
@@ -12568,10 +12710,11 @@
# resp.run.graph.nodes[0].job_details.job_runs[0].notification_property.notify_delay_after #=> Integer
# resp.run.graph.nodes[0].job_details.job_runs[0].glue_version #=> String
# resp.run.graph.nodes[0].job_details.job_runs[0].dpu_seconds #=> Float
# resp.run.graph.nodes[0].job_details.job_runs[0].execution_class #=> String, one of "FLEX", "STANDARD"
# resp.run.graph.nodes[0].job_details.job_runs[0].maintenance_window #=> String
+ # resp.run.graph.nodes[0].job_details.job_runs[0].profile_name #=> String
# resp.run.graph.nodes[0].crawler_details.crawls #=> Array
# resp.run.graph.nodes[0].crawler_details.crawls[0].state #=> String, one of "RUNNING", "CANCELLING", "CANCELLED", "SUCCEEDED", "FAILED", "ERROR"
# resp.run.graph.nodes[0].crawler_details.crawls[0].started_on #=> Time
# resp.run.graph.nodes[0].crawler_details.crawls[0].completed_on #=> Time
# resp.run.graph.nodes[0].crawler_details.crawls[0].error_message #=> String
@@ -12731,10 +12874,11 @@
# resp.runs[0].graph.nodes[0].job_details.job_runs[0].notification_property.notify_delay_after #=> Integer
# resp.runs[0].graph.nodes[0].job_details.job_runs[0].glue_version #=> String
# resp.runs[0].graph.nodes[0].job_details.job_runs[0].dpu_seconds #=> Float
# resp.runs[0].graph.nodes[0].job_details.job_runs[0].execution_class #=> String, one of "FLEX", "STANDARD"
# resp.runs[0].graph.nodes[0].job_details.job_runs[0].maintenance_window #=> String
+ # resp.runs[0].graph.nodes[0].job_details.job_runs[0].profile_name #=> String
# resp.runs[0].graph.nodes[0].crawler_details.crawls #=> Array
# resp.runs[0].graph.nodes[0].crawler_details.crawls[0].state #=> String, one of "RUNNING", "CANCELLING", "CANCELLED", "SUCCEEDED", "FAILED", "ERROR"
# resp.runs[0].graph.nodes[0].crawler_details.crawls[0].started_on #=> Time
# resp.runs[0].graph.nodes[0].crawler_details.crawls[0].completed_on #=> Time
# resp.runs[0].graph.nodes[0].crawler_details.crawls[0].error_message #=> String
@@ -13694,10 +13838,11 @@
# resp.sessions[0].worker_type #=> String, one of "Standard", "G.1X", "G.2X", "G.025X", "G.4X", "G.8X", "Z.2X"
# resp.sessions[0].completed_on #=> Time
# resp.sessions[0].execution_time #=> Float
# resp.sessions[0].dpu_seconds #=> Float
# resp.sessions[0].idle_timeout #=> Integer
+ # resp.sessions[0].profile_name #=> String
# resp.next_token #=> String
#
# @see http://docs.aws.amazon.com/goto/WebAPI/glue-2017-03-31/ListSessions AWS API Documentation
#
# @overload list_sessions(params = {})
@@ -13880,10 +14025,50 @@
def list_triggers(params = {}, options = {})
req = build_request(:list_triggers, params)
req.send_request(options)
end
+ # List all the Glue usage profiles.
+ #
+ # @option params [String] :next_token
+ # A continuation token, included if this is a continuation call.
+ #
+ # @option params [Integer] :max_results
+ # The maximum number of usage profiles to return in a single response.
+ #
+ # @return [Types::ListUsageProfilesResponse] Returns a {Seahorse::Client::Response response} object which responds to the following methods:
+ #
+ # * {Types::ListUsageProfilesResponse#profiles #profiles} => Array<Types::UsageProfileDefinition>
+ # * {Types::ListUsageProfilesResponse#next_token #next_token} => String
+ #
+ # The returned {Seahorse::Client::Response response} is a pageable response and is Enumerable. For details on usage see {Aws::PageableResponse PageableResponse}.
+ #
+ # @example Request syntax with placeholder values
+ #
+ # resp = client.list_usage_profiles({
+ # next_token: "OrchestrationToken",
+ # max_results: 1,
+ # })
+ #
+ # @example Response structure
+ #
+ # resp.profiles #=> Array
+ # resp.profiles[0].name #=> String
+ # resp.profiles[0].description #=> String
+ # resp.profiles[0].created_on #=> Time
+ # resp.profiles[0].last_modified_on #=> Time
+ # resp.next_token #=> String
+ #
+ # @see http://docs.aws.amazon.com/goto/WebAPI/glue-2017-03-31/ListUsageProfiles AWS API Documentation
+ #
+ # @overload list_usage_profiles(params = {})
+ # @param [Hash] params ({})
+ def list_usage_profiles(params = {}, options = {})
+ req = build_request(:list_usage_profiles, params)
+ req.send_request(options)
+ end
+
# Lists names of workflows created in the account.
#
# @option params [String] :next_token
# A continuation token, if this is a continuation request.
#
@@ -17203,10 +17388,64 @@
def update_trigger(params = {}, options = {})
req = build_request(:update_trigger, params)
req.send_request(options)
end
+ # Update an Glue usage profile.
+ #
+ # @option params [required, String] :name
+ # The name of the usage profile.
+ #
+ # @option params [String] :description
+ # A description of the usage profile.
+ #
+ # @option params [required, Types::ProfileConfiguration] :configuration
+ # A `ProfileConfiguration` object specifying the job and session values
+ # for the profile.
+ #
+ # @return [Types::UpdateUsageProfileResponse] Returns a {Seahorse::Client::Response response} object which responds to the following methods:
+ #
+ # * {Types::UpdateUsageProfileResponse#name #name} => String
+ #
+ # @example Request syntax with placeholder values
+ #
+ # resp = client.update_usage_profile({
+ # name: "NameString", # required
+ # description: "DescriptionString",
+ # configuration: { # required
+ # session_configuration: {
+ # "NameString" => {
+ # default_value: "ConfigValueString",
+ # allowed_values: ["ConfigValueString"],
+ # min_value: "ConfigValueString",
+ # max_value: "ConfigValueString",
+ # },
+ # },
+ # job_configuration: {
+ # "NameString" => {
+ # default_value: "ConfigValueString",
+ # allowed_values: ["ConfigValueString"],
+ # min_value: "ConfigValueString",
+ # max_value: "ConfigValueString",
+ # },
+ # },
+ # },
+ # })
+ #
+ # @example Response structure
+ #
+ # resp.name #=> String
+ #
+ # @see http://docs.aws.amazon.com/goto/WebAPI/glue-2017-03-31/UpdateUsageProfile AWS API Documentation
+ #
+ # @overload update_usage_profile(params = {})
+ # @param [Hash] params ({})
+ def update_usage_profile(params = {}, options = {})
+ req = build_request(:update_usage_profile, params)
+ req.send_request(options)
+ end
+
# Updates an existing function definition in the Data Catalog.
#
# @option params [String] :catalog_id
# The ID of the Data Catalog where the function to be updated is
# located. If none is provided, the Amazon Web Services account ID is
@@ -17312,10 +17551,10 @@
operation: config.api.operation(operation_name),
client: self,
params: params,
config: config)
context[:gem_name] = 'aws-sdk-glue'
- context[:gem_version] = '1.178.0'
+ context[:gem_version] = '1.179.0'
Seahorse::Client::Request.new(handlers, context)
end
# @api private
# @deprecated