diff --git a/.gitignore b/.gitignore
index 82f9275..69ce56b 100644
--- a/.gitignore
+++ b/.gitignore
@@ -160,3 +160,46 @@ cython_debug/
 #  and can be added to the global gitignore or merged into this file.  For a more nuclear
 #  option (not recommended) you can uncomment the following to ignore the entire idea folder.
 #.idea/
+
+# Created by https://www.toptal.com/developers/gitignore/api/terraform
+# Edit at https://www.toptal.com/developers/gitignore?templates=terraform
+
+### Terraform ###
+# Local .terraform directories
+**/.terraform/*
+
+# .tfstate files
+*.tfstate
+*.tfstate.*
+
+# Crash log files
+crash.log
+crash.*.log
+
+# Exclude all .tfvars files, which are likely to contain sensitive data, such as
+# password, private keys, and other secrets. These should not be part of version
+# control as they are data points which are potentially sensitive and subject
+# to change depending on the environment.
+*.tfvars
+*.tfvars.json
+
+# Ignore override files as they are usually used to override resources locally and so
+# are not checked in
+override.tf
+override.tf.json
+*_override.tf
+*_override.tf.json
+
+# Include override files you do wish to add to version control using negated pattern
+# !example_override.tf
+
+# Include tfplan files to ignore the plan output of command: terraform plan -out=tfplan
+# example: *tfplan*
+
+# Ignore CLI configuration files
+.terraformrc
+terraform.rc
+
+# End of https://www.toptal.com/developers/gitignore/api/terraform
+
+.DS_Store
\ No newline at end of file
diff --git a/CHANGELOG.md b/CHANGELOG.md
new file mode 100644
index 0000000..bd48566
--- /dev/null
+++ b/CHANGELOG.md
@@ -0,0 +1,5 @@
+### Changelog
+
+All notable changes to this project will be documented in this file. Dates are displayed in UTC.
+
+Generated by [`auto-changelog`](https://github.com/CookPete/auto-changelog).
diff --git a/README.md b/README.md
index 0db49d9..8825a29 100644
--- a/README.md
+++ b/README.md
@@ -1 +1,65 @@
-# latam-challenge
\ No newline at end of file
+# latam-challenge
+
+## Setup
+
+Apis to be enabled:
+
+- Billing API
+- Cloud Functions API
+- Pub/Sub API
+- Bigquery API
+- IAM API
+
+## 1. Deploy infrastructure
+
+### 1.1 Initialization
+
+> **Constraint:** tested using Terraform v1.8.1
+
+```bash
+cd infra
+terraform init
+```
+
+Create a new file called terraform.tfvars with the following information:
+
+```md
+project_id=<YOUR_GCP_PROJECT_ID>
+region=<YOUR_GCP_REGION>
+```
+
+### 1.2 Plan
+
+```bash
+terraform plan -var-file=terraform.tfvars
+```
+
+### 1.3 Apply
+
+```bash
+terraform apply -var-file=terraform.tfvars
+```
+
+## 2. Test the deployed infrastructure
+
+### 2.1 Ingest data
+
+```bash
+curl -m 310 -X POST https://<fn_ingest_data_url> \
+-H "Authorization: bearer $(gcloud auth print-identity-token)" -H "Content-Type: application/json" \
+-d '{
+    "product_id": "45678",
+    "product_name": "Laptop 2",
+    "category": "Electronics",
+    "unit_price": 999.99,
+    "supplier": "TechSupplier Inc."
+}'
+```
+
+### 2.2 Query data
+
+```bash
+curl -m 310 -X POST https://<fn_fetch_data_url> \
+-H "Authorization: bearer $(gcloud auth print-identity-token)" -H "Content-Type: application/json" \
+-d '{}'
+```
\ No newline at end of file
diff --git a/infra/.terraform.lock.hcl b/infra/.terraform.lock.hcl
new file mode 100644
index 0000000..fafef46
--- /dev/null
+++ b/infra/.terraform.lock.hcl
@@ -0,0 +1,41 @@
+# This file is maintained automatically by "terraform init".
+# Manual edits may be lost in future updates.
+
+provider "registry.terraform.io/hashicorp/archive" {
+  version = "2.6.0"
+  hashes = [
+    "h1:upAbF0KeKLAs3UImwwp5veC7jRcLnpKWVjkbd4ziWhM=",
+    "zh:29273484f7423b7c5b3f5df34ccfc53e52bb5e3d7f46a81b65908e7a8fd69072",
+    "zh:3cba58ec3aea5f301caf2acc31e184c55d994cc648126cac39c63ae509a14179",
+    "zh:55170cd17dbfdea842852c6ae2416d057fec631ba49f3bb6466a7268cd39130e",
+    "zh:7197db402ba35631930c3a4814520f0ebe980ae3acb7f8b5a6f70ec90dc4a388",
+    "zh:78d5eefdd9e494defcb3c68d282b8f96630502cac21d1ea161f53cfe9bb483b3",
+    "zh:8bf7fe0915d7fb152a3a6b9162614d2ec82749a06dba13fab3f98d33c020ec4f",
+    "zh:8ce811844fd53adb0dabc9a541f8cb43aacfa7d8e39324e4bd3592b3428f5bfb",
+    "zh:bca795bca815b8ac90e3054c0a9ab1ccfb16eedbb3418f8ad473fc5ad6bf0ef7",
+    "zh:d9355a18df5a36cf19580748b23249de2eb445c231c36a353709f8f40a6c8432",
+    "zh:dc32cc32cfd8abf8752d34f2a783de0d3f7200c573b885ecb64ece5acea173b4",
+    "zh:ef498e20391bf7a280d0fd6fd6675621c85fbe4e92f0f517ae4394747db89bde",
+    "zh:f2bc5226c765b0c8055a7b6207d0fe1eb9484e3ec8880649d158827ac6ed3b22",
+  ]
+}
+
+provider "registry.terraform.io/hashicorp/google" {
+  version     = "6.2.0"
+  constraints = "6.2.0"
+  hashes = [
+    "h1:7TKW5gYtdDdKsw1ClsmMvMmXYJ8ZS3Jj2XAQ2PE6UL8=",
+    "zh:08a7dc0b53d2b63baab928e66086bf3e09107516af078ce011d2667456e64834",
+    "zh:1cf9a1373e516844b43fdcea36e73f5a68f19ad07afcf6093788eb235c710163",
+    "zh:2d4a7cb26c3f0d036d51db219a09013d3d779e44d584e0fc631df0f2cd5e5550",
+    "zh:47e1fc68e455f99f1875deaed9aa5434a852e2a70a3cb5a5e9b5a2d8c25d7b74",
+    "zh:78531a8624ddcd45277e1b465e773ac92001ea0e200e9dc1147ebeb24d56359e",
+    "zh:a76751723c034d44764df22925178f78d8b4852e3e6ac6c5d86f51666c9e666c",
+    "zh:a83a59a7e667cfffb0d501a501e9b3d2d4fcc83deb07a318c9690d537cbdc4b6",
+    "zh:b16473b7e59e01690d8234a0044c304505688f5518b205e9ed06fc63ddc82977",
+    "zh:b957648ad0383e17149bf3a02def81ebc6bd55ca0cffb6ec1c368a1b4f33c4fd",
+    "zh:e2f3f4a27b41a20bdbb7a80fbcde1a4c36bbd1c83edb9256bc1724754f8d370f",
+    "zh:ecfce738f85a81603aa51162d5237d6faaa2ffc0f0e52694f8b420ad761a8957",
+    "zh:f569b65999264a9416862bca5cd2a6177d94ccb0424f3a4ef424428912b9cb3c",
+  ]
+}
diff --git a/infra/README.md b/infra/README.md
new file mode 100644
index 0000000..f55e75f
--- /dev/null
+++ b/infra/README.md
@@ -0,0 +1,55 @@
+## Requirements
+
+| Name | Version |
+|------|---------|
+| <a name="requirement_google"></a> [google](#requirement\_google) | 6.2.0 |
+
+## Providers
+
+| Name | Version |
+|------|---------|
+| <a name="provider_archive"></a> [archive](#provider\_archive) | 2.6.0 |
+| <a name="provider_google"></a> [google](#provider\_google) | 6.2.0 |
+
+## Modules
+
+No modules.
+
+## Resources
+
+| Name | Type |
+|------|------|
+| [google_bigquery_dataset.ecommerce_analytics](https://registry.terraform.io/providers/hashicorp/google/6.2.0/docs/resources/bigquery_dataset) | resource |
+| [google_bigquery_table.product_sales_table](https://registry.terraform.io/providers/hashicorp/google/6.2.0/docs/resources/bigquery_table) | resource |
+| [google_cloudfunctions2_function.fn_fetch_data](https://registry.terraform.io/providers/hashicorp/google/6.2.0/docs/resources/cloudfunctions2_function) | resource |
+| [google_cloudfunctions2_function.fn_ingest_data](https://registry.terraform.io/providers/hashicorp/google/6.2.0/docs/resources/cloudfunctions2_function) | resource |
+| [google_project_iam_member.data_engineering_bigquery_data_editor](https://registry.terraform.io/providers/hashicorp/google/6.2.0/docs/resources/project_iam_member) | resource |
+| [google_project_iam_member.data_engineering_bigquery_user](https://registry.terraform.io/providers/hashicorp/google/6.2.0/docs/resources/project_iam_member) | resource |
+| [google_project_iam_member.data_engineering_cloudfunctions](https://registry.terraform.io/providers/hashicorp/google/6.2.0/docs/resources/project_iam_member) | resource |
+| [google_project_iam_member.data_engineering_pubsub](https://registry.terraform.io/providers/hashicorp/google/6.2.0/docs/resources/project_iam_member) | resource |
+| [google_pubsub_subscription.product_sales_subscription](https://registry.terraform.io/providers/hashicorp/google/6.2.0/docs/resources/pubsub_subscription) | resource |
+| [google_pubsub_topic.product_sales_topic](https://registry.terraform.io/providers/hashicorp/google/6.2.0/docs/resources/pubsub_topic) | resource |
+| [google_service_account.data_engineering](https://registry.terraform.io/providers/hashicorp/google/6.2.0/docs/resources/service_account) | resource |
+| [google_storage_bucket.staging_bucket](https://registry.terraform.io/providers/hashicorp/google/6.2.0/docs/resources/storage_bucket) | resource |
+| [google_storage_bucket_object.fetch_data_source_object](https://registry.terraform.io/providers/hashicorp/google/6.2.0/docs/resources/storage_bucket_object) | resource |
+| [google_storage_bucket_object.ingest_data_source_object](https://registry.terraform.io/providers/hashicorp/google/6.2.0/docs/resources/storage_bucket_object) | resource |
+| [archive_file.fetch_data_source_code_archive](https://registry.terraform.io/providers/hashicorp/archive/latest/docs/data-sources/file) | data source |
+| [archive_file.ingestion_source_code_archive](https://registry.terraform.io/providers/hashicorp/archive/latest/docs/data-sources/file) | data source |
+
+## Inputs
+
+| Name | Description | Type | Default | Required |
+|------|-------------|------|---------|:--------:|
+| <a name="input_environment"></a> [environment](#input\_environment) | The environment | `string` | n/a | yes |
+| <a name="input_project_id"></a> [project\_id](#input\_project\_id) | The project ID | `string` | n/a | yes |
+| <a name="input_region"></a> [region](#input\_region) | The region | `string` | n/a | yes |
+
+## Outputs
+
+| Name | Description |
+|------|-------------|
+| <a name="output_ecommerce_analytics_dataset_id"></a> [ecommerce\_analytics\_dataset\_id](#output\_ecommerce\_analytics\_dataset\_id) | n/a |
+| <a name="output_fn_ingest_data_url"></a> [fn\_ingest\_data\_url](#output\_fn\_ingest\_data\_url) | n/a |
+| <a name="output_product_sales_subscription_name"></a> [product\_sales\_subscription\_name](#output\_product\_sales\_subscription\_name) | n/a |
+| <a name="output_product_sales_table_id"></a> [product\_sales\_table\_id](#output\_product\_sales\_table\_id) | n/a |
+| <a name="output_product_sales_topic_name"></a> [product\_sales\_topic\_name](#output\_product\_sales\_topic\_name) | n/a |
diff --git a/infra/bigquery.tf b/infra/bigquery.tf
new file mode 100644
index 0000000..4df48e6
--- /dev/null
+++ b/infra/bigquery.tf
@@ -0,0 +1,57 @@
+// Bigquery dataset "ecommerce_analytics"
+resource "google_bigquery_dataset" "ecommerce_analytics" {
+  dataset_id                  = "ecommerce_analytics"
+  project                     = var.project_id
+  location                    = var.region
+  default_table_expiration_ms = "2592000000" # 30 days in milliseconds
+  labels = {
+    env = var.environment
+  }
+}
+
+# Bigquery table "ecommerce_analytics.sales"
+resource "google_bigquery_table" "product_sales_table" {
+  dataset_id          = google_bigquery_dataset.ecommerce_analytics.dataset_id
+  table_id            = "product_sales"
+  deletion_protection = true
+  time_partitioning {
+    type = "DAY"
+  }
+
+  // Bigquery table schema
+  // product_id: STRING
+  // product_name: STRING
+  // category: STRING
+  // unit_price: FLOAT
+  // supplier: STRING
+
+  schema = <<EOF
+  [
+    {
+      "name": "product_id",
+      "type": "STRING",
+      "mode": "REQUIRED"
+    },
+    {
+      "name": "product_name",
+      "type": "STRING",
+      "mode": "REQUIRED"
+    },
+    {
+      "name": "category",
+      "type": "STRING",
+      "mode": "REQUIRED"
+    },
+    {
+      "name": "unit_price",
+      "type": "FLOAT",
+      "mode": "REQUIRED"
+    },
+    {
+      "name": "supplier",
+      "type": "STRING",
+      "mode": "REQUIRED"
+    }
+  ]
+    EOF
+}
\ No newline at end of file
diff --git a/infra/iam_roles.tf b/infra/iam_roles.tf
new file mode 100644
index 0000000..b0d4aea
--- /dev/null
+++ b/infra/iam_roles.tf
@@ -0,0 +1,31 @@
+// Service account for the resources
+resource "google_service_account" "data_engineering" {
+  account_id   = "data-engineering"
+  display_name = "Data Engineering Service Account"
+  project      = var.project_id
+}
+
+// Grant the service account the necessary roles to use pub/sub, cloud functions and bigquery
+resource "google_project_iam_member" "data_engineering_pubsub" {
+  project = var.project_id
+  role    = "roles/pubsub.editor"
+  member  = "serviceAccount:${google_service_account.data_engineering.email}"
+}
+
+resource "google_project_iam_member" "data_engineering_bigquery_user" {
+  project = var.project_id
+  role    = "roles/bigquery.user"
+  member  = "serviceAccount:${google_service_account.data_engineering.email}"
+}
+resource "google_project_iam_member" "data_engineering_bigquery_data_editor" {
+  project = var.project_id
+  role    = "roles/bigquery.dataEditor"
+  member  = "serviceAccount:${google_service_account.data_engineering.email}"
+}
+
+resource "google_project_iam_member" "data_engineering_cloudfunctions" {
+  project = var.project_id
+  role    = "roles/cloudfunctions.developer"
+  member  = "serviceAccount:${google_service_account.data_engineering.email}"
+}
+
diff --git a/infra/main.tf b/infra/main.tf
new file mode 100644
index 0000000..70fb544
--- /dev/null
+++ b/infra/main.tf
@@ -0,0 +1,97 @@
+// Data sources for the Cloud Functions source code
+
+data "archive_file" "ingestion_source_code_archive" {
+  type        = "zip"
+  source_dir  = "../product_sales/ingestion"
+  output_path = "/tmp/ingestion.zip"
+}
+
+data "archive_file" "fetch_data_source_code_archive" {
+  type        = "zip"
+  source_dir  = "../product_sales/fetch"
+  output_path = "/tmp/fetch.zip"
+}
+
+
+// Storage bucket for the Cloud Functions source code
+resource "google_storage_bucket" "staging_bucket" {
+  name     = "${var.project_id}-staging"
+  project  = var.project_id
+  location = var.region
+}
+
+// Storage bucket objects for the Cloud Functions source code
+resource "google_storage_bucket_object" "ingest_data_source_object" {
+  name   = "ingestion.zip"
+  bucket = google_storage_bucket.staging_bucket.name
+  source = data.archive_file.ingestion_source_code_archive.output_path
+}
+
+resource "google_storage_bucket_object" "fetch_data_source_object" {
+  name   = "fetch.zip"
+  bucket = google_storage_bucket.staging_bucket.name
+  source = data.archive_file.fetch_data_source_code_archive.output_path
+}
+
+// Cloud Function "product_sales" to ingest product sales data
+
+resource "google_cloudfunctions2_function" "fn_ingest_data" {
+  name        = "ingest-data"
+  location    = var.region
+  description = "Ingest product sales data"
+
+  build_config {
+    runtime     = "python39"
+    entry_point = "ingest_data" # Set the entry point
+    source {
+      storage_source {
+        bucket = google_storage_bucket.staging_bucket.name
+        object = google_storage_bucket_object.ingest_data_source_object.name
+      }
+    }
+  }
+
+  service_config {
+    max_instance_count = 1
+    available_memory   = "256M"
+    timeout_seconds    = 300
+    environment_variables = {
+      BIGQUERY_DATASET = google_bigquery_dataset.ecommerce_analytics.dataset_id
+      BIGQUERY_TABLE   = google_bigquery_table.product_sales_table.table_id
+      GCP_PROJECT      = var.project_id
+      PUBSUB_TOPIC     = google_pubsub_topic.product_sales_topic.name
+    }
+    service_account_email = google_service_account.data_engineering.email
+  }
+}
+
+// Cloud Function "fetch_data" to fetch product sales data
+
+resource "google_cloudfunctions2_function" "fn_fetch_data" {
+  name        = "fetch-data"
+  location    = var.region
+  description = "Fetch product sales data"
+
+  build_config {
+    runtime     = "python39"
+    entry_point = "fetch_data" # Set the entry point
+    source {
+      storage_source {
+        bucket = google_storage_bucket.staging_bucket.name
+        object = google_storage_bucket_object.fetch_data_source_object.name
+      }
+    }
+  }
+
+  service_config {
+    max_instance_count = 1
+    available_memory   = "256M"
+    timeout_seconds    = 300
+    environment_variables = {
+      GCP_PROJECT      = var.project_id
+      BIGQUERY_DATASET = google_bigquery_dataset.ecommerce_analytics.dataset_id
+      BIGQUERY_TABLE   = google_bigquery_table.product_sales_table.table_id
+    }
+    service_account_email = google_service_account.data_engineering.email
+  }
+}
\ No newline at end of file
diff --git a/infra/outputs.tf b/infra/outputs.tf
new file mode 100644
index 0000000..6b6d358
--- /dev/null
+++ b/infra/outputs.tf
@@ -0,0 +1,19 @@
+output "ecommerce_analytics_dataset_id" {
+  value = google_bigquery_dataset.ecommerce_analytics.dataset_id
+}
+
+output "product_sales_table_id" {
+  value = google_bigquery_table.product_sales_table.table_id
+}
+
+output "product_sales_topic_name" {
+  value = google_pubsub_topic.product_sales_topic.name
+}
+
+output "product_sales_subscription_name" {
+  value = google_pubsub_subscription.product_sales_subscription.name
+}
+
+output "fn_ingest_data_url" {
+  value = google_cloudfunctions2_function.fn_ingest_data.url
+}
\ No newline at end of file
diff --git a/infra/provider.tf b/infra/provider.tf
new file mode 100644
index 0000000..e548e06
--- /dev/null
+++ b/infra/provider.tf
@@ -0,0 +1,13 @@
+terraform {
+  required_providers {
+    google = {
+      source  = "hashicorp/google"
+      version = "6.2.0"
+    }
+  }
+}
+
+provider "google" {
+  project = var.project_id
+  region  = var.region
+}
\ No newline at end of file
diff --git a/infra/pubsub.tf b/infra/pubsub.tf
new file mode 100644
index 0000000..f49fe36
--- /dev/null
+++ b/infra/pubsub.tf
@@ -0,0 +1,27 @@
+// Pub/Sub topic "product_sales"
+resource "google_pubsub_topic" "product_sales_topic" {
+  name    = "product_sales_topic"
+  project = var.project_id
+  labels = {
+    env = var.environment
+  }
+  message_retention_duration = "86600s" # 1 day
+  depends_on                 = [google_project_iam_member.data_engineering_pubsub]
+}
+
+// Pub/Sub subscription "product_sales"
+resource "google_pubsub_subscription" "product_sales_subscription" {
+  name    = "product_sales_subscription"
+  topic   = google_pubsub_topic.product_sales_topic.name
+  project = var.project_id
+  labels = {
+    env = var.environment
+  }
+
+  bigquery_config {
+    table                 = "${var.project_id}.${google_bigquery_dataset.ecommerce_analytics.dataset_id}.${google_bigquery_table.product_sales_table.table_id}"
+    service_account_email = google_service_account.data_engineering.email
+    use_table_schema      = true
+  }
+  depends_on = [google_project_iam_member.data_engineering_pubsub, google_bigquery_table.product_sales_table]
+}
\ No newline at end of file
diff --git a/infra/variables.tf b/infra/variables.tf
new file mode 100644
index 0000000..8dd1777
--- /dev/null
+++ b/infra/variables.tf
@@ -0,0 +1,14 @@
+variable "project_id" {
+  type        = string
+  description = "The project ID"
+}
+
+variable "region" {
+  type        = string
+  description = "The region"
+}
+
+variable "environment" {
+  type        = string
+  description = "The environment"
+}
\ No newline at end of file
diff --git a/product_sales/fetch/main.py b/product_sales/fetch/main.py
new file mode 100644
index 0000000..d7b0e7a
--- /dev/null
+++ b/product_sales/fetch/main.py
@@ -0,0 +1,46 @@
+import os
+from google.cloud import bigquery
+from flask import jsonify
+
+# Definir variables de entorno
+PROJECT_ID = os.getenv('GCP_PROJECT')
+DATASET_ID = os.getenv('BIGQUERY_DATASET')
+TABLE_ID = os.getenv('BIGQUERY_TABLE')
+
+def fetch_data(request):
+    """Cloud Function para consultar datos desde BigQuery"""
+    
+    # Inicializar cliente de BigQuery
+    client = bigquery.Client()
+
+    # Definir el nombre completo de la tabla
+    table_ref = f"{PROJECT_ID}.{DATASET_ID}.{TABLE_ID}"
+
+    # Especificar la consulta SQL
+    query = f"""
+        SELECT product_id, product_name, category, unit_price, supplier
+        FROM `{table_ref}`
+        LIMIT 10
+    """
+
+    # Ejecutar la consulta
+    try:
+        query_job = client.query(query)  # Ejecutar la consulta
+        results = query_job.result()     # Obtener los resultados
+
+        # Convertir los resultados a un formato JSON
+        data = []
+        for row in results:
+            data.append({
+                "product_id": row.product_id,
+                "product_name": row.product_name,
+                "category": row.category,
+                "unit_price": row.unit_price,
+                "supplier": row.supplier
+            })
+
+        return jsonify(data), 200
+
+    except Exception as e:
+        print(f'Error al consultar BigQuery: {e}')
+        return jsonify({"error": str(e)}), 500
diff --git a/product_sales/fetch/requirements.txt b/product_sales/fetch/requirements.txt
new file mode 100644
index 0000000..804d035
--- /dev/null
+++ b/product_sales/fetch/requirements.txt
@@ -0,0 +1,2 @@
+Flask==3.0.3
+google-cloud-bigquery==3.25.0
\ No newline at end of file
diff --git a/product_sales/ingestion/main.py b/product_sales/ingestion/main.py
new file mode 100644
index 0000000..253b399
--- /dev/null
+++ b/product_sales/ingestion/main.py
@@ -0,0 +1,42 @@
+import json
+from google.cloud import pubsub_v1
+from flask import jsonify, request
+import os
+
+# Define variables de entorno para el proyecto y el nombre del topic
+PROJECT_ID = os.getenv('GCP_PROJECT')
+PUBSUB_TOPIC = os.getenv('PUBSUB_TOPIC')
+
+def ingest_data(request):
+    """Cloud Function para enviar datos dinámicos a una suscripción de Pub/Sub"""
+    
+    # Verificar si la solicitud es POST y tiene un cuerpo
+    if request.method != 'POST':
+        return jsonify({"error": "Método no permitido. Usa POST."}), 405
+
+    try:
+        # Leer el cuerpo de la solicitud y convertir a JSON
+        request_json = request.get_json()
+        
+        # Validar que el cuerpo de la solicitud tenga los campos necesarios
+        required_fields = ["product_id", "product_name", "category", "unit_price", "supplier"]
+        for field in required_fields:
+            if field not in request_json:
+                return jsonify({"error": f"Falta el campo requerido: {field}"}), 400
+        
+        # Convertir los datos a formato JSON
+        message_json = json.dumps(request_json)
+        message_bytes = message_json.encode('utf-8')
+
+        # Publicar mensaje en el topic de Pub/Sub
+        publisher = pubsub_v1.PublisherClient()
+        topic_path = publisher.topic_path(PROJECT_ID, PUBSUB_TOPIC)
+
+        future = publisher.publish(topic_path, data=message_bytes)
+        future.result()  # Esperar a que el mensaje sea publicado
+
+        return jsonify({"message": "Mensaje publicado con éxito."}), 200
+
+    except Exception as e:
+        print(f'Error al publicar mensaje: {e}')
+        return jsonify({"error": str(e)}), 500
diff --git a/product_sales/ingestion/requirements.txt b/product_sales/ingestion/requirements.txt
new file mode 100644
index 0000000..e62ceb6
--- /dev/null
+++ b/product_sales/ingestion/requirements.txt
@@ -0,0 +1,2 @@
+google-cloud-pubsub==2.23.1
+Flask==3.0.3
\ No newline at end of file