Utilisation de la tâche de profilage des données dans le flux de travail du package

Dans Business Intelligence Development Studio, créez un nouveau package Integration Services.

Ajoutez un gestionnaire de connexions ADO.NET au package. Configurez ce gestionnaire de connexions pour qu'il utilise le fournisseur de données .NET pour SQL Server (SqlClient) et se connecte à une instance disponible de la base de données AdventureWorks.

Par défaut, le gestionnaire de connexions a le nom suivant : <nom_serveur>.AdventureWorks1.

Ajoutez un gestionnaire de connexions de fichiers au package. Configurez ce gestionnaire de connexions pour créer le fichier de sortie pour la tâche de profilage des données.

Cet exemple utilise le nom de fichier, DataProfile1.xml. Par défaut, le gestionnaire de connexions a le même nom que le fichier.

Ajoutez une tâche de profilage des données au flux de contrôle.

Ouvrez l'Éditeur de tâche de profilage de données pour configurer la tâche.

Dans la page Général de l'éditeur, pour Destination, sélectionnez le nom du gestionnaire de connexions de fichiers que vous avez configuré précédemment.

Dans la page Demandes de profil de l'éditeur, créez un nouveau profil de ratio Null de la colonne.

Dans le volet Propriétés de la demande, pour ConnectionManager, sélectionnez le gestionnaire de connexions ADO.NET que vous avez configuré précédemment. Ensuite, pour TableOrView, sélectionnez Person.Address.

Fermez l'Éditeur de tâche de profilage de données.

Ajoutez une tâche de script au flux de contrôle.

Connectez la tâche de script à la tâche de profilage des données.

Ouvrez l' éditeur de tâche de script pour configurer la tâche.

Dans la page Script, sélectionnez votre langage de programmation préféré. Ensuite, rendez les deux variables de package disponibles pour le script:

1. Pour ReadOnlyVariables, sélectionnez ProfileConnectionName.

2. Pour ReadWriteVariables, sélectionnez AddressLine2NullRatio.

Sélectionnez Modifier le script pour ouvrir l'environnement de développement de script.

Ajoutez une référence à l'espace de noms System.Xml.

Entrez l'exemple de code qui correspond à votre langage de programmation :

Imports System
Imports Microsoft.SqlServer.Dts.Runtime
Imports System.Xml

Public Class ScriptMain

  Private FILENAME As String = "C:\ TEMP\DataProfile1.xml"
  Private PROFILE_NAMESPACE_URI As String = "https://schemas.microsoft.com/DataDebugger/"
  Private NULLCOUNT_XPATH As String = _
    "/default:DataProfile/default:DataProfileOutput/default:Profiles" & _
    "/default:ColumnNullRatioProfile[default:Column[@Name='AddressLine2']]/default:NullCount/text()"
  Private TABLE_XPATH As String = _
    "/default:DataProfile/default:DataProfileOutput/default:Profiles" & _
    "/default:ColumnNullRatioProfile[default:Column[@Name='AddressLine2']]/default:Table"

  Public Sub Main()

    Dim profileConnectionName As String
    Dim profilePath As String
    Dim profileOutput As New XmlDocument
    Dim profileNSM As XmlNamespaceManager
    Dim nullCountNode As XmlNode
    Dim nullCount As Integer
    Dim tableNode As XmlNode
    Dim rowCount As Integer
    Dim nullRatio As Double

    ' Open output file.
    profileConnectionName = Dts.Variables("ProfileConnectionName").Value.ToString()
    profilePath = Dts.Connections(profileConnectionName).ConnectionString
    profileOutput.Load(profilePath)
    profileNSM = New XmlNamespaceManager(profileOutput.NameTable)
    profileNSM.AddNamespace("default", PROFILE_NAMESPACE_URI)

    ' Get null count for column.
    nullCountNode = profileOutput.SelectSingleNode(NULLCOUNT_XPATH, profileNSM)
    nullCount = CType(nullCountNode.Value, Integer)

    ' Get row count for table.
    tableNode = profileOutput.SelectSingleNode(TABLE_XPATH, profileNSM)
    rowCount = CType(tableNode.Attributes("RowCount").Value, Integer)

    ' Compute and return null ratio.
    nullRatio = nullCount / rowCount
    Dts.Variables("AddressLine2NullRatio").Value = nullRatio

    Dts.TaskResult = Dts.Results.Success

  End Sub

End Class

using System;
using Microsoft.SqlServer.Dts.Runtime;
using System.Xml;

public class ScriptMain
{

  private string FILENAME = "C:\\ TEMP\\DataProfile1.xml";
  private string PROFILE_NAMESPACE_URI = "https://schemas.microsoft.com/DataDebugger/";
  private string NULLCOUNT_XPATH = "/default:DataProfile/default:DataProfileOutput/default:Profiles" + "/default:ColumnNullRatioProfile[default:Column[@Name='AddressLine2']]/default:NullCount/text()";
  private string TABLE_XPATH = "/default:DataProfile/default:DataProfileOutput/default:Profiles" + "/default:ColumnNullRatioProfile[default:Column[@Name='AddressLine2']]/default:Table";

  public void Main()
  {

    string profileConnectionName;
    string profilePath;
    XmlDocument profileOutput = new XmlDocument();
    XmlNamespaceManager profileNSM;
    XmlNode nullCountNode;
    int nullCount;
    XmlNode tableNode;
    int rowCount;
    double nullRatio;

    // Open output file.
    profileConnectionName = Dts.Variables["ProfileConnectionName"].Value.ToString();
    profilePath = Dts.Connections[profileConnectionName].ConnectionString;
    profileOutput.Load(profilePath);
    profileNSM = new XmlNamespaceManager(profileOutput.NameTable);
    profileNSM.AddNamespace("default", PROFILE_NAMESPACE_URI);

    // Get null count for column.
    nullCountNode = profileOutput.SelectSingleNode(NULLCOUNT_XPATH, profileNSM);
    nullCount = (int)nullCountNode.Value;

    // Get row count for table.
    tableNode = profileOutput.SelectSingleNode(TABLE_XPATH, profileNSM);
    rowCount = (int)tableNode.Attributes["RowCount"].Value;

    // Compute and return null ratio.
    nullRatio = nullCount / rowCount;
    Dts.Variables["AddressLine2NullRatio"].Value = nullRatio;

    Dts.TaskResult = Dts.Results.Success;

  }

}

Fermez l'environnement de développement de script, puis l'éditeur de tâche de script.