def create_pubsub_client(credentials):
    http = httplib2.Http()
    credentials.authorize(http)
    return discovery.build('pubsub', 'v1beta2', http=http)
Build the pubsub client.
dataset/ETHPy150Open GoogleCloudPlatform/kubernetes-bigquery-python/pubsub/pubsub-pipe-image/utils.py/create_pubsub_client