Ver código fonte

feat(rabbitmq): add routing keys and exchanges for ad click and impression events

Dave 2 meses atrás
pai
commit
45b2590ace
9 arquivos alterados com 92 adições e 0 exclusões
  1. 11 0
      .env.app
  2. 11 0
      .env.app.dev
  3. 11 0
      .env.app.test
  4. 11 0
      .env.mgnt
  5. 10 0
      .env.mgnt.dev
  6. 11 0
      .env.mgnt.test
  7. 9 0
      .env.stats
  8. 9 0
      .env.stats.dev
  9. 9 0
      .env.stats.test

+ 11 - 0
.env.app

@@ -39,6 +39,17 @@ RABBITMQ_URL="amqp://boxrabbit:BoxRabbit%232025@localhost:5672"
 RABBITMQ_LOGIN_EXCHANGE="stats.user"
 RABBITMQ_LOGIN_QUEUE="stats.user.login.q"
 RABBITMQ_LOGIN_ROUTING_KEY="user.login"
+RABBITMQ_ADS_CLICK_ROUTING_KEY="stats.ad.click"
+# Stats Events Queues & Routing Keys
+RABBITMQ_STATS_EXCHANGE="stats.user"
+RABBITMQ_STATS_AD_CLICK_QUEUE="stats.ad.click"
+RABBITMQ_STATS_AD_CLICK_ROUTING_KEY="stats.ad.click"
+RABBITMQ_STATS_VIDEO_CLICK_QUEUE="stats.video.click"
+RABBITMQ_STATS_VIDEO_CLICK_ROUTING_KEY="stats.video.click"
+RABBITMQ_STATS_AD_IMPRESSION_QUEUE="stats.ad.impression"
+RABBITMQ_STATS_AD_IMPRESSION_ROUTING_KEY="stats.ad.impression"
+
+
 # Recommendation Service Config
 # Channel boost multiplier for same-channel videos (1.0 = no boost, 1.2 = 20% boost)
 RECOMMENDATION_CHANNEL_BOOST=1.1

+ 11 - 0
.env.app.dev

@@ -38,6 +38,17 @@ RABBITMQ_URL="amqp://boxrabbit:BoxRabbit%232025@localhost:5672"
 RABBITMQ_LOGIN_EXCHANGE="stats.user"
 RABBITMQ_LOGIN_QUEUE="stats.user.login.q"
 RABBITMQ_LOGIN_ROUTING_KEY="user.login"
+RABBITMQ_ADS_CLICK_ROUTING_KEY="stats.ad.click"
+# Stats Events Queues & Routing Keys
+RABBITMQ_STATS_EXCHANGE="stats.user"
+RABBITMQ_STATS_AD_CLICK_QUEUE="stats.ad.click"
+RABBITMQ_STATS_AD_CLICK_ROUTING_KEY="stats.ad.click"
+RABBITMQ_STATS_VIDEO_CLICK_QUEUE="stats.video.click"
+RABBITMQ_STATS_VIDEO_CLICK_ROUTING_KEY="stats.video.click"
+RABBITMQ_STATS_AD_IMPRESSION_QUEUE="stats.ad.impression"
+RABBITMQ_STATS_AD_IMPRESSION_ROUTING_KEY="stats.ad.impression"
+
+
 # Recommendation Service Config
 # Channel boost multiplier for same-channel videos (1.0 = no boost, 1.2 = 20% boost)
 RECOMMENDATION_CHANNEL_BOOST=1.1

+ 11 - 0
.env.app.test

@@ -39,6 +39,17 @@ RABBITMQ_URL="amqp://boxrabbit:BoxRabbit%232025@localhost:5672"
 RABBITMQ_LOGIN_EXCHANGE="stats.user"
 RABBITMQ_LOGIN_QUEUE="stats.user.login.q"
 RABBITMQ_LOGIN_ROUTING_KEY="user.login"
+RABBITMQ_ADS_CLICK_ROUTING_KEY="stats.ad.click"
+# Stats Events Queues & Routing Keys
+RABBITMQ_STATS_EXCHANGE="stats.user"
+RABBITMQ_STATS_AD_CLICK_QUEUE="stats.ad.click"
+RABBITMQ_STATS_AD_CLICK_ROUTING_KEY="stats.ad.click"
+RABBITMQ_STATS_VIDEO_CLICK_QUEUE="stats.video.click"
+RABBITMQ_STATS_VIDEO_CLICK_ROUTING_KEY="stats.video.click"
+RABBITMQ_STATS_AD_IMPRESSION_QUEUE="stats.ad.impression"
+RABBITMQ_STATS_AD_IMPRESSION_ROUTING_KEY="stats.ad.impression"
+
+
 # Recommendation Service Config
 # Channel boost multiplier for same-channel videos (1.0 = no boost, 1.2 = 20% boost)
 RECOMMENDATION_CHANNEL_BOOST=1.1

+ 11 - 0
.env.mgnt

@@ -25,10 +25,21 @@ REDIS_DB=0
 REDIS_KEY_PREFIX=box:
 
 # RabbitMQ Config: RABBITMQ_URL="amqp://boxrabbit:BoxRabbit#2025@localhost:5672"
+# RabbitMQ Config
 RABBITMQ_URL="amqp://boxrabbit:BoxRabbit%232025@localhost:5672"
 RABBITMQ_LOGIN_EXCHANGE="stats.user"
 RABBITMQ_LOGIN_QUEUE="stats.user.login.q"
 RABBITMQ_LOGIN_ROUTING_KEY="user.login"
+RABBITMQ_ADS_CLICK_ROUTING_KEY="stats.ad.click"
+# Stats Events Queues & Routing Keys
+RABBITMQ_STATS_EXCHANGE="stats.user"
+RABBITMQ_STATS_AD_CLICK_QUEUE="stats.ad.click"
+RABBITMQ_STATS_AD_CLICK_ROUTING_KEY="stats.ad.click"
+RABBITMQ_STATS_VIDEO_CLICK_QUEUE="stats.video.click"
+RABBITMQ_STATS_VIDEO_CLICK_ROUTING_KEY="stats.video.click"
+RABBITMQ_STATS_AD_IMPRESSION_QUEUE="stats.ad.impression"
+RABBITMQ_STATS_AD_IMPRESSION_ROUTING_KEY="stats.ad.impression"
+
 
 # App set to 0.0.0.0 for local LAN access
 APP_HOST=0.0.0.0

+ 10 - 0
.env.mgnt.dev

@@ -14,10 +14,20 @@ REDIS_DB=0
 REDIS_KEY_PREFIX=box:
 
 # RabbitMQ Config: RABBITMQ_URL="amqp://boxrabbit:BoxRabbit#2025@localhost:5672"
+# RabbitMQ Config
 RABBITMQ_URL="amqp://boxrabbit:BoxRabbit%232025@localhost:5672"
 RABBITMQ_LOGIN_EXCHANGE="stats.user"
 RABBITMQ_LOGIN_QUEUE="stats.user.login.q"
 RABBITMQ_LOGIN_ROUTING_KEY="user.login"
+RABBITMQ_ADS_CLICK_ROUTING_KEY="stats.ad.click"
+# Stats Events Queues & Routing Keys
+RABBITMQ_STATS_EXCHANGE="stats.user"
+RABBITMQ_STATS_AD_CLICK_QUEUE="stats.ad.click"
+RABBITMQ_STATS_AD_CLICK_ROUTING_KEY="stats.ad.click"
+RABBITMQ_STATS_VIDEO_CLICK_QUEUE="stats.video.click"
+RABBITMQ_STATS_VIDEO_CLICK_ROUTING_KEY="stats.video.click"
+RABBITMQ_STATS_AD_IMPRESSION_QUEUE="stats.ad.impression"
+RABBITMQ_STATS_AD_IMPRESSION_ROUTING_KEY="stats.ad.impression"
 
 
 # App set to 0.0.0.0 for local LAN access

+ 11 - 0
.env.mgnt.test

@@ -14,10 +14,21 @@ REDIS_DB=0
 REDIS_KEY_PREFIX=box:
 
 # RabbitMQ Config: RABBITMQ_URL="amqp://boxrabbit:BoxRabbit#2025@localhost:5672"
+# RabbitMQ Config
 RABBITMQ_URL="amqp://boxrabbit:BoxRabbit%232025@localhost:5672"
 RABBITMQ_LOGIN_EXCHANGE="stats.user"
 RABBITMQ_LOGIN_QUEUE="stats.user.login.q"
 RABBITMQ_LOGIN_ROUTING_KEY="user.login"
+RABBITMQ_ADS_CLICK_ROUTING_KEY="stats.ad.click"
+# Stats Events Queues & Routing Keys
+RABBITMQ_STATS_EXCHANGE="stats.user"
+RABBITMQ_STATS_AD_CLICK_QUEUE="stats.ad.click"
+RABBITMQ_STATS_AD_CLICK_ROUTING_KEY="stats.ad.click"
+RABBITMQ_STATS_VIDEO_CLICK_QUEUE="stats.video.click"
+RABBITMQ_STATS_VIDEO_CLICK_ROUTING_KEY="stats.video.click"
+RABBITMQ_STATS_AD_IMPRESSION_QUEUE="stats.ad.impression"
+RABBITMQ_STATS_AD_IMPRESSION_ROUTING_KEY="stats.ad.impression"
+
 
 # App set to 0.0.0.0 for local LAN access
 APP_HOST=0.0.0.0

+ 9 - 0
.env.stats

@@ -32,6 +32,15 @@ RABBITMQ_URL="amqp://boxrabbit:BoxRabbit%232025@localhost:5672"
 RABBITMQ_LOGIN_EXCHANGE="stats.user"
 RABBITMQ_LOGIN_QUEUE="stats.user.login.q"
 RABBITMQ_LOGIN_ROUTING_KEY="user.login"
+RABBITMQ_ADS_CLICK_ROUTING_KEY="stats.ad.click"
+# Stats Events Queues & Routing Keys
+RABBITMQ_STATS_EXCHANGE="stats.user"
+RABBITMQ_STATS_AD_CLICK_QUEUE="stats.ad.click"
+RABBITMQ_STATS_AD_CLICK_ROUTING_KEY="stats.ad.click"
+RABBITMQ_STATS_VIDEO_CLICK_QUEUE="stats.video.click"
+RABBITMQ_STATS_VIDEO_CLICK_ROUTING_KEY="stats.video.click"
+RABBITMQ_STATS_AD_IMPRESSION_QUEUE="stats.ad.impression"
+RABBITMQ_STATS_AD_IMPRESSION_ROUTING_KEY="stats.ad.impression"
 
 # Stats Aggregation Scheduler (runs every 5 minutes)
 # Set to 'false' to disable scheduled aggregation (manual trigger only via API)

+ 9 - 0
.env.stats.dev

@@ -33,6 +33,15 @@ RABBITMQ_URL="amqp://boxrabbit:BoxRabbit%232025@localhost:5672"
 RABBITMQ_LOGIN_EXCHANGE="stats.user"
 RABBITMQ_LOGIN_QUEUE="stats.user.login.q"
 RABBITMQ_LOGIN_ROUTING_KEY="user.login"
+RABBITMQ_ADS_CLICK_ROUTING_KEY="stats.ad.click"
+# Stats Events Queues & Routing Keys
+RABBITMQ_STATS_EXCHANGE="stats.user"
+RABBITMQ_STATS_AD_CLICK_QUEUE="stats.ad.click"
+RABBITMQ_STATS_AD_CLICK_ROUTING_KEY="stats.ad.click"
+RABBITMQ_STATS_VIDEO_CLICK_QUEUE="stats.video.click"
+RABBITMQ_STATS_VIDEO_CLICK_ROUTING_KEY="stats.video.click"
+RABBITMQ_STATS_AD_IMPRESSION_QUEUE="stats.ad.impression"
+RABBITMQ_STATS_AD_IMPRESSION_ROUTING_KEY="stats.ad.impression"
 
 # Stats Aggregation Scheduler (runs every 5 minutes)
 # Set to 'false' to disable scheduled aggregation (manual trigger only via API)

+ 9 - 0
.env.stats.test

@@ -32,6 +32,15 @@ RABBITMQ_URL="amqp://boxrabbit:BoxRabbit%232025@localhost:5672"
 RABBITMQ_LOGIN_EXCHANGE="stats.user"
 RABBITMQ_LOGIN_QUEUE="stats.user.login.q"
 RABBITMQ_LOGIN_ROUTING_KEY="user.login"
+RABBITMQ_ADS_CLICK_ROUTING_KEY="stats.ad.click"
+# Stats Events Queues & Routing Keys
+RABBITMQ_STATS_EXCHANGE="stats.user"
+RABBITMQ_STATS_AD_CLICK_QUEUE="stats.ad.click"
+RABBITMQ_STATS_AD_CLICK_ROUTING_KEY="stats.ad.click"
+RABBITMQ_STATS_VIDEO_CLICK_QUEUE="stats.video.click"
+RABBITMQ_STATS_VIDEO_CLICK_ROUTING_KEY="stats.video.click"
+RABBITMQ_STATS_AD_IMPRESSION_QUEUE="stats.ad.impression"
+RABBITMQ_STATS_AD_IMPRESSION_ROUTING_KEY="stats.ad.impression"
 
 # Stats Aggregation Scheduler (runs every 5 minutes)
 # Set to 'false' to disable scheduled aggregation (manual trigger only via API)