Uploaded image for project: 'Subscription Watch'
  1. Subscription Watch
  2. SWATCH-4546

Data Engineering: Implement Snowpipe Ingestion Pipelines for initial S3 Buckets Preprod

XMLWordPrintable

    • Icon: Task Task
    • Resolution: Unresolved
    • Icon: Normal Normal
    • None
    • None
    • dataverse
    • None
    • 5
    • False
    • Hide

      None

      Show
      None
    • False
    • Impediment
    • subs-swatch-thunder

      PO/Tech Lead NOTE: Developer Pairing Opportunity

      Implement and configure Snowpipe pipelines for preprod through production environments to automate data ingestion from S3 buckets into Snowflake.

       

      Promote Snowpipe migration file and source binding to preprod:
       Example dev pr: https://gitlab.cee.redhat.com/dataverse/dataverse-config/dataproduct-config/-/merge_requests/5237/diffs 

      Create Pipes for each s3 bucket:

      • ocp_cluster_data
      • sku_product_tag
        _ subscriptions _This is the floorist export
      • tally

      (not yet implemented in floorist)

      • tally_snapshots
      • tally_measurements
        _ subscription _This is the raw table
      • subscription_measurements
      • hosts
      • host_tally_buckets

      Acceptance Criteria:

      • For environments preprod
      • When new data is added to the s3 buckets, then the snowflake stages are populated.
      • Snowflake Snowpipe DB- We need to verify record count matches Floorist export

              Unassigned Unassigned
              kflahert@redhat.com Kevin Flaherty
              Votes:
              0 Vote for this issue
              Watchers:
              1 Start watching this issue

                Created:
                Updated: