import generator
import time
from google.cloud import pubsub_v1
from pipelineanalytics import PROJECT, TOPIC_NAME


SLEEP_TIME = 1


def publish_message(project=PROJECT, topic_name=TOPIC_NAME):




def simulate_datastream():
    while True:



if __name__ == '__main__':
   simulate_datastream()
