KustoStep Class

KustoStep enables the functionality of running Kusto queries on a target Kusto cluster in Azure ML Pipelines.

Initialize KustoStep.

Inheritance

azureml.pipeline.core._kusto_step_base._KustoStepBase

KustoStep

Constructor

KustoStep(name, compute_target, database_name, query_directory, output, parameter_dict=None, allow_reuse=False)

Parameters

Name	Description
name Required	str Name of the step
compute_target Required	str Name of the Kusto compute
database_name Required	str Name of the Kusto database to query from
query_directory Required	str Path to directory that contains a single file with Kusto query
output Required	Union[PipelineData, OutputPortBinding] Output port definition for outputs produced by this step
parameter_dict	dict Dictionary that maps the parameter name to parameter value in Kusto query default value: None
allow_reuse	bool Boolean that indicates whether the step should reuse previous results with same settings/inputs default value: False
name Required	str Name of the step
compute_target Required	str Name of the Kusto compute
database_name Required	str Name of the Kusto database to query from
query_directory Required	str Path to directory that contains a single file with Kusto query
output Required	Union[PipelineData, OutputPortBinding] Output port definition for outputs produced by this step
parameter_dict Required	dict[str, object] Dictionary that maps the parameter name to parameter value in Kusto query
allow_reuse Required	bool Boolean that indicates whether the step should reuse previous results with same settings/inputs

Methods

create_node

Create a node from the Kusto step and add it to the specified graph. This method is not intended to be used directly. When a pipeline is instantiated with this step, Azure ML automatically passes the parameters required through this method so that step can be added to a pipeline graph that represents the workflow.

create_node

Create a node from the Kusto step and add it to the specified graph.

This method is not intended to be used directly. When a pipeline is instantiated with this step, Azure ML automatically passes the parameters required through this method so that step can be added to a pipeline graph that represents the workflow.

create_node(graph, default_datastore, context)

Parameters

Name	Description
graph Required	Graph The graph object to add the node to.
default_datastore Required	AbstractAzureStorageDatastore The default datastore.
context Required	<xref:azureml.pipeline.core._GraphContext> The graph context.

Returns

Type	Description
Node	The created node.