stefanopassador

version: "3.8"
services:
  streaming-publisher:
    build: ./streaming-publisher/
  batch-subscriber:
    build: ./batch-subscriber/
    depends_on: 
      - mongodb
  mongodb:
    image: arm64v8/mongo:4.0

stefanopassador

FROM python:latest
WORKDIR /code
ADD batch-subscription-service-account.json batch-subscription-service-account.json
ADD requirements.txt requirements.txt
RUN pip install -r requirements.txt
COPY app.py app.py
CMD ["python", "-u", "app.py"]

stefanopassador

import os
import time
import random
import json
from google.cloud import pubsub_v1
from pymongo import MongoClient

## GCP config
PROJECT_ID = 'streaming-ingestion-XXXXXX'
TOPIC_ID = 'sample-topic'

stefanopassador

import os
import time
import random
import json
from google.cloud import pubsub_v1

## GCP config
PROJECT_ID = 'streaming-ingestion-XXXXXX'
TOPIC_ID = 'sample-topic'
SUBSCRIPTION_ID = 'sample-topic-sub'

stefanopassador

FROM python:latest
WORKDIR /code
ADD streaming-publisher-service-account.json streaming-publisher-service-account.json
ADD requirements.txt requirements.txt
RUN pip install -r requirements.txt
COPY app.py app.py
CMD ["python", "-u", "app.py"]