def __init__(self):
    self.parse_args()
    self.uuid = str(uuid.uuid4())
    self.topic_name = (self.args.topic_name + self.uuid)
    self.subscription_name = (self.args.subscription_name + self.uuid)
    publish_client = pubsub.Client(project=self.project)
    topic = publish_client.topic(self.topic_name)
    if topic.exists():
        logging.info('deleting topic %s', self.topic_name)
        topic.delete()
    logging.info('creating topic %s', self.topic_name)
    topic.create()
    sub = topic.subscription(self.subscription_name)
    if sub.exists():
        logging.info('deleting sub %s', self.topic_name)
        sub.delete()
    logging.info('creating sub %s', self.topic_name)
    sub.create()
def __init__(self):
    self.parse_args()
    self.uuid = str(uuid.uuid4())
    self.topic_name = (self.args.topic_name + self.uuid)
    self.subscription_name = (self.args.subscription_name + self.uuid)
    publish_client = pubsub.Client(project=self.project)
    topic = publish_client.topic(self.topic_name)
    if topic.exists():
        logging.info('deleting topic %s', self.topic_name)
        topic.delete()
    logging.info('creating topic %s', self.topic_name)
    topic.create()
    sub = topic.subscription(self.subscription_name)
    if sub.exists():
        logging.info('deleting sub %s', self.topic_name)
        sub.delete()
    logging.info('creating sub %s', self.topic_name)
    sub.create()