Creazione di una trasformazione asincrona con il componente script

Introduzione ai componenti di trasformazione asincroni

Quando si aggiunge un componente script alla scheda Flusso di dati di Progettazione SSIS, viene visualizzata la finestra di dialogo Seleziona tipo componente script in cui si richiede di preconfigurare il componente come origine, trasformazione o destinazione. In questa finestra di dialogo selezionare Trasformazione.

Configurazione di un componente di trasformazione asincrono in modalità di progettazione metadati

Dopo aver selezionato l'opzione per creare un componente di trasformazione, configurare il componente utilizzando Editor trasformazione Script. Per ulteriori informazioni, vedere Configurazione del componente script nell'editor corrispondente.

Per selezionare il linguaggio di scripting che verrà utilizzato dal componente script, impostare la proprietà ScriptLanguage nella pagina Script della finestra di dialogo Editor trasformazione Script.

Un componente di trasformazione del flusso di dati include un input e supporta uno o più output. La configurazione dell'input e degli output del componente è uno dei passaggi che è necessario completare in modalità di progettazione metadati, tramite Editor trasformazione Script, prima di scrivere lo script personalizzato.

Configurazione delle colonne di input

Configurazione di input, output e colonne di output

Aggiunta di variabili

Scripting di un componente di trasformazione asincrono in modalità di progettazione codice

Dopo aver configurato tutti i metadati per il componente, è possibile scrivere lo script personalizzato. Nella pagina Script di Editor trasformazione Script fare clic su Modifica script per aprire l'IDE di Microsoft Visual Studio Tools for Applications (VSTA), in cui è possibile aggiungere lo script personalizzato. Il linguaggio di scripting che si utilizza varia a seconda che sia stato selezionato Microsoft Visual Basic 2008 o Microsoft Visual C# 2008 come linguaggio di scripting per la proprietà ScriptLanguage nella pagina Script.

Per importanti informazioni applicabili a tutti i tipi di componenti creati tramite il componente script, vedere Codifica e debug del componente script.

Informazioni sul codice generato automaticamente

Scrittura di codice personalizzato

Esempio

In questo esempio è illustrato il codice personalizzato necessario nella classe ScriptMain per creare un componente di trasformazione asincrono.

In questo esempio viene illustrato un componente di trasformazione asincrono con due output. Questa trasformazione passa le colonne AddressID e City a un output, mentre conta il numero di indirizzi di una specifica città (Redmond, Washington, U.S.A.), quindi restituisce il valore risultante a un secondo output.

Se si desidera eseguire questo codice di esempio, è necessario configurare il pacchetto e il componente come segue:

1. Aggiungere un nuovo componente script all'area di progettazione del flusso di dati e configurarlo come trasformazione.

2. Connettere l'output di un'origine o di un'altra trasformazione al nuovo componente di trasformazione nella finestra di progettazione. Questo output deve fornire i dati della tabella Person.Address del database di esempio AdventureWorks2008R2 che contiene almeno le colonne AddressID e City.

3. Aprire Editor trasformazione Script. Nella pagina Colonne di input selezionare le colonne AddressID e City.

4. Nella pagina Input e output aggiungere e configurare le colonne di output AddressID e City nel primo output. Aggiungere un secondo output, quindi aggiungere una colonna di output per il valore di riepilogo nel secondo output. Impostare la proprietà SynchronousInputID del primo output su 0, perché in questo esempio ogni riga di input viene copiata in modo esplicito nel primo output. La proprietà SynchronousInputID dell'output appena creato è già impostata su 0.

5. Rinominare l'input, gli output e la nuova colonna di output specificando nomi più descrittivi. Nell'esempio si utilizzano MyAddressInput come nome dell'input, MyAddressOutput e MySummaryOutput per gli output e MyRedmondCount per la colonna di output nel secondo output.

6. Nella pagina Script fare clic su Modifica script e immettere lo script seguente. Chiudere quindi l'ambiente di sviluppo dello script e Editor trasformazione Script.

7. Creare e configurare un componente di destinazione per il primo output in cui sono previste le colonne AddressID e City, ad esempio una destinazione di SQL Server, oppure il componente di destinazione di esempio illustrato in Creazione di una destinazione con il componente script. Connettere quindi il primo output della trasformazione, MyAddressOutput, al componente di destinazione. Per creare una tabella di destinazione, è possibile eseguire il comando Transact-SQL seguente nel database AdventureWorks2008R2:

   CREATE TABLE [Person].[Address2](
       [AddressID] [int] NOT NULL,
       [City] [nvarchar](30) NOT NULL
   )
   

8. Creare e configurare un altro componente di destinazione per il secondo output. Connettere quindi il secondo output della trasformazione, MySummaryOutput, al componente di destinazione. Poiché il secondo output scrive una singola riga con un singolo valore, è possibile configurare facilmente una destinazione con una gestione connessione file flat che si connette a un nuovo file con una singola colonna. Nell'esempio questa colonna di destinazione è denominata MyRedmondCount.

9. Eseguire l'esempio.

Public Class ScriptMain
    Inherits UserComponent

    Private myRedmondAddressCount As Integer

    Public Overrides Sub CreateNewOutputRows()

        MySummaryOutputBuffer.AddRow()

    End Sub

    Public Overrides Sub MyAddressInput_ProcessInput(ByVal Buffer As MyAddressInputBuffer)

        While Buffer.NextRow()
            MyAddressInput_ProcessInputRow(Buffer)
        End While

        If Buffer.EndOfRowset Then
            MyAddressOutputBuffer.SetEndOfRowset()
            MySummaryOutputBuffer.MyRedmondCount = myRedmondAddressCount
            MySummaryOutputBuffer.SetEndOfRowset()
        End If

    End Sub

    Public Overrides Sub MyAddressInput_ProcessInputRow(ByVal Row As MyAddressInputBuffer)

        With MyAddressOutputBuffer
            .AddRow()
            .AddressID = Row.AddressID
            .City = Row.City
        End With

        If Row.City.ToUpper = "REDMOND" Then
            myRedmondAddressCount += 1
        End If

    End Sub

End Class

public class ScriptMain:
    UserComponent

{
    private int myRedmondAddressCount;

    public override void CreateNewOutputRows()
    {

        MySummaryOutputBuffer.AddRow();

    }

    public override void MyAddressInput_ProcessInput(MyAddressInputBuffer Buffer)
    {

        while (Buffer.NextRow())
        {
            MyAddressInput_ProcessInputRow(Buffer);
        }

        if (Buffer.EndOfRowset())
        {
            MyAddressOutputBuffer.SetEndOfRowset();
            MySummaryOutputBuffer.MyRedmondCount = myRedmondAddressCount;
            MySummaryOutputBuffer.SetEndOfRowset();
        }

    }

    public override void MyAddressInput_ProcessInputRow(MyAddressInputBuffer Row)
    {

        {
            MyAddressOutputBuffer.AddRow();
            MyAddressOutputBuffer.AddressID = Row.AddressID;
            MyAddressOutputBuffer.City = Row.City;
        }

        if (Row.City.ToUpper() == "REDMOND")
        {
            myRedmondAddressCount += 1;
        }

    }

}

Vedere anche

Concetti