Mantieni tutto organizzato con le raccolte
Salva e classifica i contenuti in base alle tue preferenze.
Quando crei una pipeline di dati in Cloud Data Fusion, utilizzi una serie di fasi, chiamate nodi, per spostare e gestire i dati man mano che scorrono dall'origine allo scopo.
Ogni nodo è costituito da un plug-in, un modulo personalizzabile che estende le funzionalità di Cloud Data Fusion.
Puoi trovare i plug-in nell'interfaccia web di Cloud Data Fusion nella pagina Studio. Per altri plug-in, fai clic su Hub.
Tipi di plug-in
I plug-in sono classificati nelle seguenti categorie:
Fonti
Trasformazioni
Analytics
Sink
Condizioni e azioni
Gestori degli errori e avvisi
Fonti
I plug-in origine si connettono a database, file o flussi in tempo reale da cui la pipeline legge i dati. Puoi configurare le origini per la pipeline di dati utilizzando l'interfaccia web, in modo da non doverti preoccupare di scrivere il codice per le connessioni di basso livello.
Trasformazioni
I plug-in di trasformazione modificano i dati dopo che sono stati importati da un'origine. Ad esempio, puoi clonare un record, modificare il formato del file in JSON o utilizzare il plug-in JavaScript per creare una trasformazione personalizzata.
Analytics
I plug-in di analisi eseguono aggregazioni, ad esempio l'unione di dati provenienti da diverse origini ed eseguire operazioni di analisi e machine learning.
Sink
I plug-in di destinazione scrivono i dati in risorse come Cloud Storage,
BigQuery, Spanner, database relazionali, file system
e mainframe. Puoi eseguire query sui dati scritti nello scommettitore utilizzando l'interfaccia web o l'API REST di Cloud Data Fusion.
Condizioni e azioni
Utilizza i plug-in di condizioni e azioni per pianificare le azioni che si verificano durante un
flussi di lavoro che non manipolano direttamente i dati al suo interno. Ad esempio:
Utilizza il plug-in Database per pianificare l'esecuzione di un comando del database alla fine della pipeline.
Utilizza il plug-in Sposta file per attivare un'azione che sposta i file all'interno di Cloud Storage.
Gestori degli errori e avvisi
Quando le fasi rilevano valori nulli, errori logici o altre fonti di errore,
puoi utilizzare un plug-in di gestione degli errori per individuarli. Utilizza questi plug-in per trovare errori nell'output dopo un plug-in di trasformazione o analisi. Puoi scrivere gli errori in un database per sottoporli ad analisi.
[[["Facile da capire","easyToUnderstand","thumb-up"],["Il problema è stato risolto","solvedMyProblem","thumb-up"],["Altra","otherUp","thumb-up"]],[["Difficile da capire","hardToUnderstand","thumb-down"],["Informazioni o codice di esempio errati","incorrectInformationOrSampleCode","thumb-down"],["Mancano le informazioni o gli esempi di cui ho bisogno","missingTheInformationSamplesINeed","thumb-down"],["Problema di traduzione","translationIssue","thumb-down"],["Altra","otherDown","thumb-down"]],["Ultimo aggiornamento 2025-09-04 UTC."],[[["\u003cp\u003eCloud Data Fusion uses plugins, which are customizable modules, to extend its capabilities in managing and moving data through a pipeline.\u003c/p\u003e\n"],["\u003cp\u003ePlugins in Cloud Data Fusion are categorized into types such as Sources, Transformations, Analytics, Sinks, Conditions and Actions, and Error Handlers and Alerts, each serving a distinct purpose in data processing.\u003c/p\u003e\n"],["\u003cp\u003eSource plugins connect to various data origins, Transformation plugins alter ingested data, Analytics plugins perform aggregations and analysis, and Sink plugins write processed data to its destination.\u003c/p\u003e\n"],["\u003cp\u003eCondition and action plugins allow scheduling of non-data manipulation actions within workflows, while error handler plugins catch and manage errors that occur within the pipeline, allowing for more detailed analysis of them.\u003c/p\u003e\n"]]],[],null,["# Plugins overview\n\n| **Tip:** Explore the [Cloud Data Fusion plugins](/data-fusion/plugins).\n\nWhen you create a data pipeline in Cloud Data Fusion, you use a series of\nstages, known as nodes, to move and manage data as it flows from source to sink.\nEach node consists of a plugin, a customizable module that extends the\ncapabilities of Cloud Data Fusion.\n\nYou can find the plugins in Cloud Data Fusion web interface by going to\nthe **Studio** page. For more plugins, click **Hub**.\n\nPlugin types\n------------\n\nPlugins are categorized into the following categories:\n\n- Sources\n- Transformations\n- Analytics\n- Sinks\n- Conditions and actions\n- Error handlers and alerts\n\n### Sources\n\nSource plugins connect to databases, files, or real-time streams from which your\npipeline reads data. You set up sources for your data pipeline using the web\ninterface, so you don't have to worry about coding low-level connections.\n\n### Transformations\n\nTransform plugins change data after it's ingested from a source. For example,\nyou can clone a record, change the file format to JSON, or use the Javascript\nplugin to create a custom transformation.\n\n### Analytics\n\nAnalytics plugins perform aggregations, such as joining data from different\nsources and running analytics and machine learning operations.\n\n### Sinks\n\nSink plugins write data to resources, such as Cloud Storage,\nBigQuery, Spanner, relational databases, file systems,\nand mainframes. You can query the data that gets written to the sink using the\nCloud Data Fusion web interface or REST API.\n\n### Conditions and actions\n\nUse condition and action plugins to schedule actions that take place during a\nworkflow that don't directly manipulate data in the workflow. For example:\n\n- Use the Database plugin to schedule a database command to run at the end of your pipeline.\n- Use the File Move plugin to trigger an action that moves files within Cloud Storage.\n\n### Error handlers and alerts\n\nWhen stages encounter null values, logical errors, or other sources of errors,\nyou can use an error handler plugin to catch errors. Use these plugins to\nfind errors in the output after a transform or analytics plugin. You can\nwrite the errors to a database for analysis.\n\nWhat's next\n-----------\n\n- [Explore the plugins](/data-fusion/plugins).\n- [Create a data pipeline](/data-fusion/docs/create-data-pipeline) with the plugins."]]
