如何使用c# .net sdk在数据工厂管道中创建kusto活动

var context = new AuthenticationContext("https://login.microsoftonline.com/{tenant-id}");
var credentials = new ClientCredential("{client-id}", "{client-secret}");
var result = context.AcquireTokenAsync("https://management.azure.com/", credentials).Result;
var accessToken = result.AccessToken;

var client = new DataFactoryManagementClient(new TokenCredentials(accessToken)) { SubscriptionId = "{subscription-id}" };
var activity = new KustoSink
{
    Name = "KustoActivity",
    LinkedServiceName = new LinkedServiceReference { ReferenceName = "{kusto-linked-service-name}" },
    KustoWriterTable = "YourTable",
    KustoWriterDatabase = "YourDatabase",
    KustoWriterKustoCluster = "YourKustoCluster"
};

var pipelineResource = new PipelineResource
{
    Name = "YourPipeline",
    Activities = new List<Activity>
    {
        new Activity
        {
            Name = "KustoActivity",
            Type = "Kusto",
            LinkedServiceName = new LinkedServiceReference { ReferenceName = "{kusto-linked-service-name}" },
            Policy = new ActivityPolicy { Timeout = TimeSpan.FromHours(1) },
            Inputs = new List<DatasetReference> { new DatasetReference { ReferenceName = "{input-dataset-name}" } },
            Outputs = new List<DatasetReference> { new DatasetReference { ReferenceName = "{output-dataset-name}" } },
            Scheduler = new Scheduler { Frequency = "Hour", Interval = 1 }
        }
    }
};

var dataFactory = new DataFactoryResource
{
    Name = "YourDataFactory",
    Location = "East US",
    Properties = new DataFactory { Pipelines = new List<Pipeline> { pipelineResource } }
};
client.Factories.CreateOrUpdate("{resource-group-name}", "YourDataFactory", dataFactory);