Novidades (StreamInsight)

Artigo
08/01/2011

O Microsoft StreamInsight apresenta novos recursos e melhorias que aumentam o poder e a produtividade de desenvolvedores e administradores de processamento de eventos complexos.

Para obter mais informações sobre problemas conhecidos, consulte Notas de Versão (StreamInsight). Para obter informações sobre compatibilidade com versões anteriores, consulte Compatibilidade com versões anteriores (StreamInsight).

Novos recursos do StreamInsight 1.2 (junho de 2011)

Novos recursos de resiliência

O StreamInsight 1.2 apresenta o suporte a resiliência interna para falhas do sistema no processamento de fluxo de dados. Esse suporte está disponível apenas na edição Premium do StreamInsight. Para obter mais informações sobre as edições, consulte Escolhendo uma edição do StreamInsight.

Os novos recursos de resiliência permitem que você execute aplicativos críticos com um tempo de inatividade operacional mínimo, com transparência para falhas do sistema, na plataforma Windows de sua preferência, a um custo total de propriedade líder do setor. Para obter mais informações, consulte os tópicos a seguir.

Os novos recursos de resiliência também incorporam novos estados de consulta:

Inicializando. Esse estado geralmente ocorre após um dos seguintes eventos:
- A consulta foi interrompida e o usuário chamou o método Start.
- Uma consulta resiliente estava em execução e o servidor está se recuperando da falha. Para alterar o estado da consulta, o usuário deve chamar o método Start.
Definindo o ponto de verificação. A consulta está em execução e um ponto de verificação está em andamento.

Novos recursos para desenvolvedores

Os aprimoramentos na API do StreamInsight incluem os seguintes recursos:

Operadores de fluxo definidos pelo usuário

Agora você pode personalizar o processamento dos fluxos de entrada com os operadores de fluxo definidos pelo usuário. Diferente dos operadores e das agregações definidos pelo usuário, que permitem a interação com janelas, os operadores de fluxo definidos pelo usuário permitem a interação direta com o conteúdo de um fluxo, o cálculo e a geração dos resultados de modo incremental, e o gerenciamento do estado. Para obter mais informações, consulte Operadores de fluxo definidos pelo usuário.

Aprimoramentos do LINQ

Você pode usar os tipos aninhados em cargas de evento, em adaptadores e nas consultas LINQ. Para obter mais informações sobre cargas de evento, consulte Criando tipos de evento.
Também é possível usar a cláusula "let" do LINQ. Para obter mais informações, consulte a cláusula let (referência a C#).
É possível unir vários fluxos em uma única consulta. Você não está mais limitado a unir somente dois fluxos. Para obter mais informações sobre junções, consulte Junções.
É possível chamar métodos de extensão embutidos nas cláusulas "from", e não apenas na primeira cláusula "from" e nas junções.
Você pode unir fluxos em chaves de junção compostas. Por exemplo: where {x.a, x.b} equals {y.a, y.b}. Para obter mais informações sobre junções, consulte Junções.
Você pode proteger um único campo sem criar um novo tipo anônimo. Por exemplo: from x in xs select x.A em vez de from x in xs select new { x.A }. Para obter mais informações sobre projeção, consulte Projeção.
Você pode usar várias agregações em uma expressão. Por exemplo, select new {ratio = (double)win.Sum(e => e.good) / (double)win.Count()}.
É possível agrupar um novo tipo anônimo em uma cláusula "group by". Por exemplo: from x in xs group new { x.A, x.B } by new { x.C, x.D } into g, onde group new { x.A, x.B } demonstra o novo recurso. Antigamente, o seletor em uma cláusula "group by" era o tipo de entrada; por exemplo, from e in input group e by ….
Agora você pode incluir projeções em uma cláusula Take. Por exemplo, … select new { myAvg = r.Value / 10, r.SourceId }).Take(2, …). Antigamente, o seletor em uma cláusula Take era o tipo de entrada; por exemplo, from win in input.window(…) from e in … select e).Take(…).

Aprimoramentos da API

Existe uma nova sobrecarga para o método ShiftEventTime que se comporta como o nome do método. Ou seja, a nova sobrecarga desloca a hora do evento com base na quantidade da duração fornecida. A versão original desse método exigia que você especificasse a hora e a duração do evento atual para deslocar a hora do evento. Em vez de escrever ShiftEventTime(e => e.StartTime + TimeSpan.FromMinutes(15)), agora você pode escrever ShiftEventTime(e => TimeSpan.FromMinutes(15)). No entanto, você ainda pode usar a versão original do método para definir a hora do evento para uma hora específica, fornecendo um valor datetime. A versão original foi retida para compatibilidade com versões anteriores. Para obter mais informações, consulte Modificações de carimbo de data/hora.
Existe uma nova política de saída, PointAlignToWindowEnd, para janelas de saltos. A política existente, ClipToWindowEnd, gera um tamanho de janela que corresponde ao tempo de vida da operação baseada em conjunto. A nova política gera um evento pontual cuja hora de início é a hora de término da janela. Essa nova política de saída é útil quando você combina o resultado com outro fluxo, desde que haja somente um único resultado válido em cada momento determinado, que expressa o resultado de agregação mais recente nesse ponto.
Agora todas as janelas têm políticas de saída padrão: ClipToWindowEnd para janelas de instantâneo e PointAlignToWindowEnd para janelas de saltos ou janelas em cascata e para janelas de contagem.

Novos recursos de capacidade de gerenciamento e ferramentas

Agora você pode usar a infraestrutura de diagnóstico existente para monitorar e solucionar problemas de processos e consultas do StreamInsight com o Monitor de Desempenho e o Visualizador de Eventos. Também é possível acessar uma lista expandida de propriedades de diagnóstico.

Contadores de desempenho

Agora você pode usar o Monitor de Desempenho para exibir contadores para os processos, as consultas e os fluxos de entrada do servidor StreamInsight. Para obter mais informações, consulte Monitorando contadores de desempenho e eventos do StreamInsight.

Log administrativo no log de eventos do Windows

Agora você pode usar o Visualizador de Eventos do Windows para ver eventos administrativos relacionados a processos, adaptadores e consultas do StreamInsight, e ao dumper do log de eventos do Aplicativo. Para obter mais informações, consulte Monitorando contadores de desempenho e eventos do StreamInsight.

Propriedades de diagnóstico adicionais

Várias propriedades de diagnóstico novas estão disponíveis para facilitar o monitoramento e a solução de problemas. Estas são as novas propriedades:

AdapterNumberOfRunningWorkers, AdapterNumberOfRunningWorkers e AdapterNumberOfSuspendedWorkers
AdapterFirstCtiTimestamp
OperatorNumberOfWorkers
OperatorGroupIdField
QueryInstanceGroupId
StreamNumberOfWorkers
StreamMinInputEventCountAcrossWorkers e StreamMaxInputEventCountAcrossWorkers
StreamMinMemoryIncludingEventsAcrossWorkers e StreamMaxMemoryIncludingEventsAcrossWorkers

Além disso, algumas exibições disponíveis anteriormente foram removidas. Elas incluem todas as exibições relacionadas ao agendador.

Para obter mais informações, consulte Monitorando o servidor StreamInsight e as consultas.

Novos recursos do StreamInsight 1.1 (outubro de 2010)

As seguintes alterações e adições foram implementadas desde a Atualização 1 do StreamInsight 1.0. Elas foram lançadas no StreamInsight 1.1 em outubro de 2010.

Suporte para origens e coletores de eventos que implementam as interfaces IObservable ou IEnumerable. Novas classes e membros foram adicionados à API StreamInsight para oferecer suporte ao novo modelo de programação para entrada e saída como uma alternativa a adaptadores de entrada e saída normais. Estes recursos são descritos nos tópicos a seguir:
Um método Stop na classe Adapter. Este método notifica um adaptador para parar como resultado de parada ou anulação de uma consulta.
Novas versões do StreamInsight são instaladas lado a lado com versões anteriores. Para obter mais informações sobre a instalação de versões do StreamInsight, consulte:
- “Instalando uma nova versão do StreamInsight” em Instalação (StreamInsight).
- “Versões do StreamInsight” em Considerações sobre programação.

Novos recursos na Atualização 1 do StreamInsight 1.0 (junho de 2010)

As seguintes alterações e adições foram implementadas desde o StreamInsight 1.0 RTM. Elas foram lançadas simultaneamente na Atualização 1 do StreamInsight 1.0 em junho de 2010 com a Atualização Cumulativa 2 do SQL Server 2008 R2.

A API ClipEventDuration. Este novo método na classe CepStream permite usar um fluxo secundário para determinar onde recortar a duração de eventos no fluxo primário. Para obter mais informações, consulte:
- “Recortando a duração de um evento” em Modificações de carimbo de data/hora.
- ClipEventDuration<(Of <<'(TSource, TClip>)>>)
Suporte para o Microsoft .NET Framework 4 em desenvolvimento de aplicativos do StreamInsight

Para obter mais informações sobre essas alterações ou para baixar a Atualização 1 do StreamInsight 1.0, consulte o artigo da Base de Dados de Conhecimento, StreamInsight 1.0 updates that are released together with Cumulative Update package 2 for SQL Server 2008 R2 (em inglês).

Novos recursos no StreamInsight 1.0 RTM (abril de 2010)

As seguintes alterações e adições foram implementadas desde o CTP (Community Technology Preview) de novembro de 2009 do StreamInsight 1.0. Elas foram lançadas simultaneamente no StreamInsight 1.0 em abril de 2010 com o SQL Server 2008 R2.

Design e desenvolvimento

Agora é possível usar consultas do StreamInsight como blocos de construção para os aplicativos. Consultas podem ser compiladas sobre consultas existentes e em execução no momento. Para obter mais informações, consulte Compondo consultas em tempo de execução.

O suporte para fluxos de entrada sincronizados foi adicionado. Para obter mais informações, consulte Tempo avançado do aplicativo.

O tamanho máximo de um único evento do StreamInsight aumentou para 16K. Para atender campos de sistema e metadados de evento, um limite mais seguro e pragmático é 14K.

Operadores

O suporte para janelas de contagem foi adicionado. Para obter mais informações, consulte Janelas de contagem.

O suporte para operações left-anti-semi-join foi adicionado. Para obter mais informações, consulte Junções.

API

A classe AdapterFactory tem uma nova definição de interface, IDeclareAdvanceTimePolicy, que retorna uma instância de AdvanceTimeSettings. Esse é o mecanismo pelo qual é possível especificar configurações de tempo de avanço na fábrica do adaptador.

Gerenciamento

Exibições de diagnóstico

Novas exibições de diagnóstico estão disponíveis para monitorar o sistema nos seguintes níveis de especificidade: servidor, operador, agendador e adaptador. Para obter mais informações, consulte Monitorando o servidor StreamInsight e as consultas.