Определение готовности системы отслеживания измененных данных

На вкладке Поток управления конструктора служб SSIS добавьте к потоку управления контейнер «цикл по элементам».

Соедините задачу «Выполнение SQL», вычисляющую конечные точки интервала, с контейнером «цикл по элементам».

В окне Редактор циклов по элементам выберите следующие параметры.

1. В поле InitExpression введите выражение @DataReady = 0.

   Это выражение задает исходное значение для переменной цикла.

2. В поле EvalExpression введите @DataReady == 0.

   Когда это выражение принимает значение False, выполнение цикла прекращается и начинается добавочная загрузка.

В пределах контейнера «цикл по элементам» добавьте задачу «Выполнение SQL».

В окне Редактор задачи «Выполнение SQL» на странице Общие выберите следующие параметры:

1. Для параметра ResultSet выберите значение Одна строка.

2. Настройте допустимое соединение с базой данных-источником.

3. Для параметра SQLSourceType выберите значение Прямой ввод.

4. В поле SQLStatement введите приведенную ниже инструкцию SQL:

   declare @DataReady int, @TimeoutCount int
   
   if not exists (select tran_end_time from cdc.lsn_time_mapping
           where tran_end_time > ?  )
       select @DataReady = 0
   else
       if ? = 0
           select @DataReady = 3 
   else
       if not exists (select tran_end_time from cdc.lsn_time_mapping
               where tran_end_time <= ? )
           select @DataReady = 1 
   else
       select @DataReady = 2
   
   select @TimeoutCount = ?
   if (@DataReady = 0)
       select @TimeoutCount = @TimeoutCount + 1
   else
       select @TimeoutCount = 0
   
   if (@TimeoutCount > ?)
       select @DataReady = 5
   
   select @DataReady as DataReady, @TimeoutCount as TimeoutCount
   

На странице Сопоставление параметров средства Редактор задачи «Выполнение SQL» произведите следующие сопоставления.

1. Сопоставьте переменную ExtractEndTime с параметром 0.

2. Сопоставьте переменную IntervalID с параметром 1.

3. Сопоставьте переменную ExtractStartTime с параметром 2.

4. Сопоставьте переменную TimeoutCount с параметром 3.

5. Сопоставьте переменную TimeoutCeiling с параметром 4.

На странице Результирующий набор средства Редактор задачи «Выполнение SQL» сопоставьте результат DataReady с переменной DataReady и результат TimeoutCount с переменной TimeoutCount.

В пределах контейнера «цикл по элементам» добавьте задачу «Скрипт».

Соедините задачу «Выполнение SQL», которая запрашивает готовность системы отслеживания измененных данных, с новой задачей «Скрипт».

Для управления очередностью, соединяющего задачу «Выполнение SQL» с задачей «Скрипт», откройте Редактор управления очередностью и выберите следующие параметры:

1. В списке Вычислительная операция выберите пункт Выражение и ограничение.

2. Для параметра Значение выберите значение Успех.

   Ограничение по значению Успех относится к успешности выполнения предыдущей задачи. В этом случае это означает успешное выполнение задачи «Выполнение SQL».

3. В поле Выражение введите @DataReady == 0 && @TimeoutCount <= @TimeoutCeiling.

4. Установите флажок Логическое И. Все ограничения должны иметь значение True, если он еще не установлен.

В средстве Редактор задачи «Скрипт» на странице Скрипт для свойства ReadOnlyVariables выберите из списка целочисленную переменную User::DelaySeconds.

В окне Редактор задачи «Скрипт» на странице Скрипт нажмите кнопку Изменить скрипт, чтобы открыть среду разработки скриптов.

В главной процедуре введите одну из следующих строк кода.

• При программировании на языке C# введите следующую строку кода:

  System.Threading.Thread.Sleep((int)Dts.Variables["DelaySeconds"].Value * 1000);
  

  -или-

• При программировании на языке Visual Basic, введите следующую строку кода:

  System.Threading.Thread.Sleep(Ctype(Dts.Variables("DelaySeconds").Value, Integer) * 1000)
  

  Примечание
  Метод Thread.Sleep ожидает аргумент, указанный в миллисекундах.

Оставьте без изменений создаваемую по умолчанию строку кода, которая возвращает DtsExecResult.Success в результате выполнения скрипта.

Закройте среду разработки скриптов и Редактор задачи «Скрипт».

В пределах контейнера «цикл по элементам» добавьте задачу «Выполнение SQL».

Соедините задачу «Выполнение SQL», которая направляет запросы для выявления готовности измененных данных, с новой задачей «Выполнение SQL».

Для управления очередностью, которое соединяет две задачи «Выполнение SQL», откройте средство Редактор управления очередностью и выберите следующие параметры.

1. В списке Вычислительная операция выберите пункт Выражение и ограничение.

2. Для параметра Значение выберите значение Успех.

   Ограничение по значению Успешно указывает на успешное завершение предшествующей задачи «Выполнение SQL».

3. В поле Выражение введите @DataReady == 0.

4. Установите флажок Логическое И. Все ограничения должны иметь значение True, если он еще не установлен.

   При выборе этого варианта оба условия (ограничение и выражение) должны иметь значение true.

В окне Редактор задачи «Выполнение SQL» на странице Общие выберите следующие параметры:

1. Для параметра ResultSet выберите значение Одна строка.

2. Настройте допустимое соединение с базой данных-источником.

3. Для параметра SQLSourceType выберите значение Прямой ввод.

4. В поле SQLStatement введите приведенную ниже инструкцию SQL:

   WAITFOR DELAY ?
   

На странице Сопоставление параметров редактора сопоставьте строковую переменную DelaySeconds с параметром 0.

Если необходимо создать отчет об ошибке или превышении времени ожидания, записав сообщение в журнал, настройте ведение журнала для пакета. Дополнительные сведения см. в разделе Как Включение ведения журналов в пакете.

В пределах контейнера «цикл по элементам» добавьте задачу «Скрипт».

Соедините задачу «Выполнение SQL», которая запрашивает готовность системы отслеживания измененных данных, с новой задачей «Скрипт».

Для управления очередностью, соединяющего задачу «Выполнение SQL» с задачей «Скрипт», откройте Редактор управления очередностью и выберите следующие параметры:

1. В списке Вычислительная операция выберите пункт Выражение и ограничение.

2. Для параметра Значение выберите значение Успех.

   Ограничение по значению Успех относится к успешности выполнения предыдущей задачи. В этом случае это означает успешное выполнение задачи «Выполнение SQL».

3. В поле Выражение введите @DataReady == 1 || @DataReady == 5.

4. Установите флажок Логическое И. Все ограничения должны иметь значение True, если он еще не установлен.

   При выборе этого варианта оба условия (ограничение и выражения) должны иметь значение true.

В средстве Редактор задачи «Скрипт» на странице Скрипт для свойства ReadOnlyVariables выберите из списка параметры User::DataReady и User::ExtractStartTime, чтобы их значения были доступны для скрипта.

Если необходимо включить в записываемые в журнал сведения данные из определенных системных переменных (например, System::PackageName), выберите и эти переменные.

В окне Редактор задачи «Скрипт» на странице Скрипт нажмите кнопку Изменить скрипт, чтобы открыть среду разработки скриптов.

В главную процедуру добавьте код для регистрации ошибки путем вызова метода Dts.Log или создайте событие, путем вызова одного из методов интерфейса Dts.Events. Информируйте пакет об ошибке, вернув Dts.TaskResult = Dts.Results.Failure.

Следующий образец показывает, как записать сообщение в журнал. Дополнительные сведения см. в разделах Ведение журнала в задаче «Скрипт», Вызов событий в задаче «Сценарий» и Возврат результатов из задачи «Сценарий».

    ' User variables.
    Dim dataReady As Integer = _
      CType(Dts.Variables("DataReady").Value, Integer)
    Dim extractStartTime As Date = _
      CType(Dts.Variables("ExtractStartTime").Value, DateTime)

    ' System variables.
    Dim packageName As String = _
      Dts.Variables("PackageName").Value.ToString()
    Dim executionStartTime As Date = _
      CType(Dts.Variables("StartTime").Value, DateTime)

    Dim eventMessage As New System.Text.StringBuilder()

    If dataReady = 1 OrElse dataReady = 5 Then

      If dataReady = 1 Then
        eventMessage.AppendLine("Start Time Error")
      Else
        eventMessage.AppendLine("Timeout Error")
      End If

      With eventMessage
        .Append("The package ")
        .Append(packageName)
        .Append(" started at ")
        .Append(executionStartTime.ToString())
        .Append(" and ended at ")
        .AppendLine(DateTime.Now().ToString())
        If dataReady = 1 Then
          .Append("The specified ExtractStartTime was ")
          .AppendLine(extractStartTime.ToString())
        End If
      End With

      System.Windows.Forms.MessageBox.Show(eventMessage.ToString())

      Dts.Log(eventMessage.ToString(), 0, Nothing)

      Dts.TaskResult = Dts.Results.Failure

    Else

      Dts.TaskResult = Dts.Results.Success

    End If

Закройте среду разработки скриптов и Редактор задачи «Скрипт».