Google Cloud Storage

Descrizione

Connettore enterprise per Google Cloud Storage (GCS) — il blob storage service di Google Cloud Platform che è la base dell'object storage per Google itself + 6M+ paying GCP customer (alternativa a AWS S3 e Azure Blob Storage, particolarmente strong su prezzo per cold archive Coldline/Archive storage class, integrazione native con BigQuery per data lake analytics, e dual-region/multi-region per GDPR-compliant EU residency) via JSON API v1 ufficiale. Tre operazioni atomiche coprono i pattern principali del object lifecycle: listObjects (enumera object di un bucket con prefix filtering opzionale "logs/2026-" per scoping, paginazione cursor-based per bucket con milioni di object, pattern di discovery batch processing), getObjectMetadata (info dettagliata di un object specifico compreso content-type, size, md5Hash + crc32cHash per integrity check, generationNumber per versioning, mediaLink che è l'URL signed da usare per il download del payload binary), deleteObject (cancellazione con soft-delete configurabile se versioning enabled sul bucket — recovery 7gg default). Auth via OAuth2 access token con scope devstorage.read_write (oppure devstorage.read_only per use case lista-only), stored nel vault integration FlowForge tramite portal-centric OAuth2 multi-tenant pattern — refresh-token gestito centralmente, runtime tenant riceve access_token short-lived (1h TTL Google) via JWE handoff 5min. Validation enterprise pre-API: bucket name validato sintatticamente come RFC GCS strict (3-63 char lowercase + numeri + - + . without leading/trailing dash + not IP-like — Google rifiuterebbe 400 altrimenti); object name validato senza control characters; ID validati numerici per generationNumber. Pipeline standard FlowForge: SSRF-safe gateway, circuit-breaker dedicato per GCS, retry exponential backoff su 5xx Google transient (rare ma succedono soprattutto su region migration eventi) + 429. Rate limit GCS: 5000 read req/sec per bucket (generoso, no concern usual use case), 1 RPS write/bucket per same-named object (anti-thrashing, raramente hit). Output: { objects? (per listObjects, array of [{ name, size, contentType, updated, md5Hash, generation }]), count?, metadata? (per getObjectMetadata), mediaLink? (per download signed URL), deleted? (per deleteObject), bucket, nextPageToken?, totalSize? }. Use case: archivia output workflow su bucket GCS per long-term retention (workflow genera PDF report → upload su GCS con storage class "Coldline" per ottimizzare costo); lista file per elaborazione batch nightly (cron orario + listObjects su prefix "incoming/" + per ogni file processa + sposta in "processed/" + delete original); pulizia automatic oggetti scaduti (lifecycle policy lato GCS + workflow di audit settimanale di verifica); genera link download signed per consegna client di file temporanei (TTL 24h dopo workflow di delivery completion); pipeline ETL da data lake GCS verso BigQuery downstream o Snowflake export; backup documenti enterprise con retention 7 anni per compliance fiscale italiana.

⚙️ Parametri di configurazione

Campi mostrati nell’editor quando si configura il nodo. Generati direttamente dal NodeDefconfigFields.

💡 Esempio configurazione

Snippet JSON del nodo come compare nel workflow. I valori sono derivati daidefaultValue e dai parametri required.

{
  "id": "node-community_gcs-1",
  "defId": "community_gcs",
  "label": "Google Cloud Storage",
  "config": {
    "operation": "listObjects",
    "bucket": "mio-bucket-prod",
    "maxResults": 100
  }
}

🔗 Nodi correlati nella stessa categoria