def create_pubsub_stub(host=PUBSUB_ENDPOINT, port=SSL_PORT):
    ssl_creds = implementations.ssl_channel_credentials(None, None, None)
    channel_creds = make_channel_creds(ssl_creds, auth_func)
    channel = implementations.secure_channel(host, port, channel_creds)
    return pubsub_pb2.beta_create_Publisher_stub(channel)
If no explicit attribute defined, retrieve value from entity.
dataset/ETHPy150Open GoogleCloudPlatform/cloud-pubsub-samples-python/grpc/pubsub_sample.py/create_pubsub_stub--crossover with--dataset/ETHPy150Open CollabQ/CollabQ/.google_appengine/google/appengine/ext/db/__init__.py/Expando.__getattr__