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

str

Required

Name of the step

compute_target

str

Required

Name of the Kusto compute

database_name

str

Required

Name of the Kusto database to query from

query_directory

str

Required

Path to directory that contains a single file with Kusto query

output

Union[PipelineData, OutputPortBinding]

Required

Output port definition for outputs produced by this step

parameter_dict

dict

default value: None

Dictionary that maps the parameter name to parameter value in Kusto query

allow_reuse

bool

default value: False

Boolean that indicates whether the step should reuse previous results with same settings/inputs

name

str

Required

Name of the step

compute_target

str

Required

Name of the Kusto compute

database_name

str

Required

Name of the Kusto database to query from

query_directory

str

Required

Path to directory that contains a single file with Kusto query

output

Union[PipelineData, OutputPortBinding]

Required

Output port definition for outputs produced by this step

parameter_dict

dict[str, object]

Required

Dictionary that maps the parameter name to parameter value in Kusto query

allow_reuse

bool

Required

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

graph

Graph

Required

The graph object to add the node to.

default_datastore

AbstractAzureStorageDatastore

Required

The default datastore.

context

<xref:azureml.pipeline.core._GraphContext>

Required

The graph context.

Returns

The created node.

Return type

Node