Orchestrate
.procfwk

Logo

A cross tenant metadata driven processing framework for Azure Data Factory and Azure Synapse Analytics achieved by coupling orchestration pipelines with a SQL database and a set of Azure Functions.


- Overview
- Contents


View the Project on GitHub mrpaulandrew/procfwk

Pipeline Request


¬ę¬†Contents / Functions / Helpers


Role

To provide a common validated set of pipeline request properties to be used with all worker pipeline interactions.

Namespace: mrpaulandrew.azure.procfwk.Helpers.

Properties

Property Name Type
TenantId string
SubscriptionId string
AuthenticationKey string
SubscriptionId string
ResourceGroupName string
OrchestratorName string
OrchestratorType PipelineServiceType
PipelineName string
PipelineParameters Dictionary<string, string>

Methods

Validate

Role: To validate all request values provided.


CheckUri

Returns: bool

Role: provides a simple validation check for values passed to the public functions as part of the request body.

Example Use:

if (RequestHelper.CheckUri(authenticationKey))
{
    log.LogInformation("Valid URL Provided");
}

CheckGuid

Returns: bool

Role: provides a simple validation check for values passed to the public functions as part of the request body.

Example Use:

if (!RequestHelper.CheckGuid(applicationId))
{
    log.Error("Invalid GUID Provided.");
}

ReportInvalidBody

Returns: InvalidRequestException

Role:

Example Use:

protected void ReportInvalidBody(ILogger logger)
{
    var msg = "Invalid body.";
    logger.LogError(msg);
    throw new InvalidRequestException(msg);
}

ParametersAsObjects

Returns: Dictionary

Role: To parse provided worker pipeline parameters and return a dictionary of values to be used by the pipeline service.

Example Use:

var dictionary = new Dictionary<string, object>();
foreach (var key in PipelineParameters.Keys)
    dictionary.Add(key, PipelineParameters[key]);
return dictionary;