Glossario (StreamInsight)

 

I termini seguenti sono applicabili a Microsoft StreamInsight.

Termini

Termine Definizione
adattatore (termine legacy) Introdotto in una versione precedente di StreamInsight, convertitore software che offre eventi all'interno o all'esterno di un server StreamInsight. Gli adattatori sono ancora supportati ma sono stati sostituiti dal modello di sink e di origine Observable/Observer. Vedere: adattatore di input, adattatore di output.
host dell'adattatore (termine legacy) Classe astratta radice Adapter che definisce l'handshake tra l'adattatore e il server StreamInsight nel punto di interazione ENQUEUE. Fornisce tutti i servizi dell'adattatore necessari, come la gestione della memoria e la gestione delle eccezioni. L'host dell'adattatore richiama i metodi implementati dal writer dell'adattatore, per conto del server. Notare che l'host dell'adattatore è trasparente all'utente.
flusso associato Un flusso di eventi contenente tutte le informazioni necessarie per produrre eventi. Le informazioni sono costituite da un'origine dati di cui è già stata creata un'istanza oppure sono sufficienti per consentire al server StreamInsight di avviare l'origine dati. Vedere: flusso di eventi, flusso non associato.
motore CEP Vedere: server StreamInsight
componibile Utilizzo dei componenti della query (oggetti o operatori) come blocchi di compilazione riutilizzabili per formare query complesse. L'operazione consiste nel collegamento dei componenti della query o nell'incapsulamento dei componenti della query l'uno all'interno dell'altro.
elaborazione di eventi complessi (CEP) Elaborazione continua e incrementale di flussi di eventi da più origini sulla base di specifiche di modello e di query dichiarative con latenza prossima a zero. L'obiettivo è quello di identificare modelli significativi, relazioni e astrazioni di dati da eventi apparentemente non correlati e di generare risposte immediate.
finestra di conteggio Le finestre di conteggio hanno una dimensione variabile definita dal conteggio delle diverse ore di inizio degli eventi lungo una sequenza temporale. Le finestre di conteggio si spostano lungo la sequenza temporale con l'ora di inizio di ogni evento distinto. Ogni nuovo evento che definisce una nuova ora di inizio dell'evento provoca pertanto la creazione di una nuova finestra di conteggio, fino al completamento del conteggio. Vedere: finestra di salto, finestra temporale scorrevole, finestra snapshot, finestra.
evento CTI (Current Time Increment) Tipo di evento utilizzato per limitare l'impatto degli eventi non ordinati o della latenza degli eventi. Il tipo di evento CTI è costituito da un singolo campo che fornisce un timestamp corrente. L'evento CTI indica al server StreamInsight che nessun evento di inserimento in entrata successivo avrà un'ora di inizio anteriore al timestamp dell'evento CTI. In altre parole, il CTI è un evento di punteggiatura speciale che indica la completezza degli eventi esistenti. Indicando la completezza, il server StreamInsight può rilasciare i risultati degli operatori di windowing o di altri operatori di aggregazione con uno stato accumulato al successivo operatore a valle.

Vedere: tipo di evento, evento di inserimento.
rimuovere dalla coda (termine legacy) Operazione utilizzata dall'adattatore di output per effettuare il pull di un evento, o di un singolo batch di eventi, dal server StreamInsight all'adattatore di output. Vedere: adattatore di output, accodare.
evento Edge Un modello di eventi Edge rappresenta un'occorrenza dell'evento il cui payload è valido per un determinato intervallo di tempo. Tuttavia, solo l'ora di inizio è nota all'arrivo al server StreamInsight. L'ora di fine dell'evento è nota in un secondo momento e viene aggiornata. Esempi di eventi Edge sono i processi Windows, gli eventi di traccia da Event Tracing for Windows (ETW), una sessione Web dell'utente o una quantizzazione di un segnale analogico.

Vedere: evento, modello di eventi, modello di eventi intervallo, intervallo di tempo, modello di eventi punto.
accodare (termine legacy) Operazione utilizzata dall'adattatore di input per effettuare il push di un evento, o di un singolo batch di eventi, dalla memoria al server StreamInsight. Vedere: adattatore di input, rimuovere dalla coda.
evento Unità di base dei dati elaborati dal server StreamInsight. Ogni evento contiene un'intestazione che definisce il tipo di evento e le proprietà temporali dell'evento. In un evento, eccetto l'evento CTI, generalmente è contenuto un payload dell'evento, vale a dire una struttura dati .NET contenente i dati associati all'evento. Vedere: payload dell'evento, modello di eventi punto, evento Edge, modello di eventi intervallo.
intestazione dell'evento Parte di un evento che ne definisce il tipo e le proprietà temporali. Nelle proprietà temporali sono incluse un'ora di inizio e un'ora di fine valide associate all'evento. Vedere: evento, tipo di evento, payload dell'evento.
tipo di evento Metadati di evento che definiscono il tipo di evento. StreamInsight supporta due tipi di evento: Insert e CTI (Current Time Increment). Vedere: evento di inserimento, evento CTI.
modello di eventi Metadati di evento che definiscono le caratteristiche temporali (forma) dell'evento. StreamInsight supporta i seguenti modelli di eventi: punto, intervallo e limite. Vedere: modello di eventi punto, modello di eventi intervallo, evento Edge.
payload dell'evento La parte di dati di un evento in cui i campi dati sono definiti come tipi CLR. Un payload dell'evento è una struttura tipizzata. Vedere: intestazione di metadati, evento.
forma dell'evento Vedere: modello di eventi.
flusso di eventi Vedere: flusso.
EventStreamGroup Una raccolta di flussi che indica che tutti i rami nei flussi vengono prodotti da un'operazione Group By. Qualsiasi operazione su EventStreamGroup funzionerà per ogni flusso nel gruppo. Il risultato di tale operazione è un gruppo di flussi.
adattatore generico (termine legacy) Vedere: adattatore non tipizzato.
finestra di salto Tipo di finestra in cui le finestre consecutive "saltano" avanti nel tempo in base a un intervallo fisso. La finestra è definita da due intervalli di tempo: la dimensione hop H e la dimensione della finestra S. Per ogni unità di tempo H viene creata una nuova finestra di dimensione S. Vedere: finestra di conteggio, finestra temporale scorrevole, finestra snapshot, finestra.
adattatore di input (termine legacy) Convertitore software tramite cui vengono accettati i flussi di eventi in entrata da origini esterne quali database, file, feed di ticker, porte di rete, dispositivi di produzione e così via. L'adattatore di input legge gli eventi in entrata nel formato in cui vengono forniti e trasforma questi dati in un formato che possa essere utilizzato dal server StreamInsight. Gli adattatori di input sono ancora supportati ma sono stati in genere sostituiti dal modello di origine Observable. Vedere: adattatore, adattatore di output.
evento di inserimento Il tipo di evento utilizzato per indicare l'arrivo di un evento nel flusso. Il tipo di evento di inserimento è costituito da metadati che definiscono la durata valida dell'evento e i campi di payload (dati) dell'evento. Vedere: evento CTI, evento.
modello di eventi intervallo Il modello di eventi che rappresenta un evento il cui payload è valido per un periodo di tempo specificato. Il modello di eventi intervallo richiede che venga fornita l'ora di inizio e di fine dell'intervallo nei metadati dell'evento. Gli eventi intervallo sono validi solo per questo specifico intervallo. Esempi includono la larghezza di un impulso elettronico, la durata (validità) di una vendita all'asta o un'attività del ticker per le azioni in cui il prezzo di offerta per l'azione è valido per un intervallo di tempo specifico. L'ora di inizio e di fine definita dalle proprietà temporali del modello determinano l'intervallo valido del payload.

Vedere: evento, modello di eventi, modello di eventi punto, evento Edge, intervallo di tempo.
LINQ Language Integrated Query. Un set di estensioni a .NET Framework che includono operazioni di trasformazione, impostazione e Language Integrated Query. Vedere: modello di query, query in esecuzione.
intestazione di metadati Vedere: intestazione dell'evento.
operatore Unità atomica di una query come pianificato dal server StreamInsight per elaborare gli eventi a cui si applica la query. Gli esempi includono SELECT, PROJECT, AGGREGATE, UNION, TOPK e JOIN. Gli operatori sono completamente componibili e dispongono di un numero specifico di input e output. Vedere: query, modello di query, componibile.
adattatore di output (termine legacy) Convertitore software tramite cui vengono ricevuti gli eventi elaborati dal server StreamInsight, vengono trasformati gli eventi in un formato previsto dal dispositivo di output e vengono trasmessi i dati al dispositivo in questione. Il dispositivo di output potrebbe essere un database, un file di testo, un PDA o altro dispositivo. Gli adattatori di output sono ancora supportati ma sono stati sostituiti dal modello di sink Observer. Vedere: adattatore, adattatore di input.
payload Vedere: payload dell'evento.
modello di eventi punto Il modello di eventi che rappresenta l'occorrenza di un evento come un singolo punto nel tempo. È una sottoclasse del modello di eventi intervallo. I metadati dell'evento punto forniscono solo un'ora di inizio valida. Il server StreamInsight deriva l'ora di fine valida aggiungendo un tick (la più piccola unità di tempo nel tipo di dati TIME sottostante) all'ora di inizio per impostare l'intervallo di tempo valido per l'evento. Gli eventi punto sono validi solo per questo singolo momento di tempo. Esempi di eventi punto sono l'arrivo di un messaggio di posta elettronica, la lettura di un misuratore o le selezioni effettuate da un utente nel Web, un tick per le azioni o una voce nel registro eventi di Windows.

Vedere: evento, modello di eventi intervallo, intervallo di tempo, evento Edge.
query Query LINQ continuamente in esecuzione nel server StreamInsight tramite cui vengono elaborati eventi ricevuti dalle origini a cui è associata la query e tramite cui vengono inviati eventi elaborati ai sink a cui è associata.
associazione di query Processo di associazione di origini e sink a una query.
modello di query (termine legacy) Unità fondamentale della composizione della query nel modello dell'adattatore. Un modello di query definisce la logica di business richiesta per analizzare ed elaborare continuamente eventi inviati al e trasmessi dal server StreamInsight. Vedere: query, associazione di query.
RankedEventStream Un flusso di eventi classificati. Questa origine del flusso è richiesta per l'operatore TopK e non è accettata come origine del flusso per qualsiasi altro operatore.
evento ritiro Tipo di evento interno utilizzato per modificare un evento di inserimento esistente modificando l'attributo EndTime dell'evento.
sink Struttura o dispositivo che consente di utilizzare eventi dal server StreamInsight. Gli esempi includono strumenti di visualizzazione, dashboard, file, tabelle, log e code di messaggi. Vedere: origine.
finestra temporale scorrevole Una finestra con la lunghezza fissa L che si sposta lungo una sequenza temporale in base agli eventi del flusso. Con ogni evento sulla sequenza temporale, viene creata una nuova finestra, a partire dall'ora di inizio dell'evento. Vedere: finestra di salto, finestra snapshot, finestra.
finestra snapshot Le finestre snapshot sono definite in base all'ora di inizio e di fine degli eventi nel flusso, anziché in base a una griglia fissa lungo la sequenza temporale. La dimensione e il periodo di tempo della finestra sono definiti solo dagli eventi nel flusso. Per ogni coppia di endpoint dell'evento (ora di inizio e ora di fine) più vicini, viene creata una finestra snapshot. In base a questa definizione, tutte le ore di inizio e di fine dell'evento rientrano nei limiti della finestra e non si trovano mai tra di essi. Le finestre snapshot dividono pertanto la sequenza temporale in base a tutte le modifiche eseguite. Vedere: finestra di conteggio, finestra di salto, finestra temporale scorrevole, finestra.
origine Struttura o dispositivo che fornisce i dati di origine al server StreamInsight. Esempi includono file, registri Web, registri di sistema, tabelle, code di messaggi, feed di mercato o notizie e sensori di produzione o logistica. Vedere: sink.
query in esecuzione Query in esecuzione nel server StreamInsight tramite cui viene eseguito il calcolo continuo sugli eventi in entrata.

Quando i singoli eventi arrivano nel server StreamInsight, questi vengono elaborati dalle query in esecuzione, che trasmettono eventi di output in risposta all'arrivo di eventi di input. Le query in esecuzione sono scritte nel framework del linguaggio LINQ.
flusso Raccolta di dati che cambia nel corso del tempo. Tutti i dati nel server StreamInsight sono organizzati in flussi.

Un flusso può essere inviato da un'origine esterna al server StreamInsight per l'elaborazione e inviato come output a un'origine esterna. Un flusso può essere anche una coda di eventi dati all'interno di una query che vengono passati da un operatore al successivo nell'albero dell'operatore durante l'elaborazione della query. Vedere: flusso temporale
consumer di flusso La struttura o il dispositivo che utilizza l'output di una query. Gli esempi sono un sink o un'altra query in esecuzione. Vedere: origine, flusso.
Debugger flusso eventi di StreamInsight Strumento autonomo nella piattaforma Microsoft StreamInsight che fornisce funzionalità di debug e analisi del flusso di eventi.
LINQ StreamInsight Implementazione di LINQ utilizzata dal server StreamInsight per elaborare e utilizzare i flussi di eventi. Le espressioni di StreamInsight LINQ sono definite nei flussi e producono flussi. Vedere: LINQ, flusso.
piattaforma StreamInsight Piattaforma completa per lo sviluppo di applicazioni CEP (Complex Event Processing, elaborazione di eventi complessi). La piattaforma è costituita dal server StreamInsight, dallo strumento Debug flusso eventi,dall' IDE di Visual Studio e da altri componenti.
runtime di StreamInsight Vedere: server StreamInsight
server StreamInsight Motore centrale e componenti del framework di Microsoft StreamInsight. Il server StreamInsight può essere utilizzato per elaborare e analizzare i flussi di eventi associati a un'applicazione CEP (Complex Event Processing, elaborazione di eventi complessi).
flusso di StreamInsight Vedere: flusso temporale.
origine del flusso Vedere: origine.
flusso temporale Sequenza di eventi con un set univoco di caratteristiche: ogni evento nel flusso dispone di un timestamp; nel flusso sono contenuti eventi CTI; gli eventi nel flusso sono conformi al modello CTI, vale a dire che quando viene visualizzato un CTI nel flusso temporale, non si disporrà più di eventi nel flusso con un timestamp precedente a quello del CTI. Un flusso temporale viene implementato tramite l'interfaccia IStreamable<> e può essere elaborato utilizzando operatori LINQ di StreamInsight. Vedere: evento CTI, flusso.
tick La più piccola unità di tempo in un tipo di dati datetime (nanosecondi).
intervallo di tempo Il periodo di tempo in cui un dato evento è valido. L'intervallo di tempo valido include l'ora di inizio valida e tutti i momenti di tempo fino all'ora di fine valida esclusa.
adattatore tipizzato (termine legacy) Adattatore tramite cui viene generato solo un singolo tipo di evento.
flusso non associato Flusso di eventi contenente la definizione del modello di eventi o il tipo di payload, ma non la definizione dell'origine dati. Vedere: flusso, flusso associato.
adattatore non tipizzato (termine legacy) Adattatore tramite cui vengono accettati o generati più tipi di evento in cui la struttura del payload o il tipo di campi nel payload non sono noti in anticipo. Esempi sono eventi da un CSV o un file di testo, una tabella SQL o un socket.

Vedere: adattatore tipizzato.
finestra Subset di eventi all'interno di un flusso che cadono nello stesso periodo di tempo, vale a dire una finestra contenente i dati dell'evento insieme a una sequenza temporale. Le finestre sono necessarie per abilitare gli operatori basati sulle finestre quali sum, avg e count, ma possono anche essere combinate con altre operazioni di elaborazione dati. Vedere: finestra di conteggio, finestra di salto, finestra temporale scorrevole, finestra snapshot.
WindowStream Un flusso di finestre in cui ogni finestra contiene una raccolta di eventi. Tutti gli eventi del flusso condividono la proprietà comune di rientrare in una o più finestre. Si potrebbe trattare di una finestra basata sul tempo la cui ora di inizio e di fine sono accessibili.

Vedere anche

Concetti relativi al server StreamInsight