René's URL Explorer Experiment

{"@context":"https://schema.org","@type":"DiscussionForumPosting","headline":"Can't reach GCP PubSub Emulator","articleBody":"I have setup the PubSub emulator to run a Python script locally pointing to it.   \r\nThe emulator is run following the tutorial and it seems to be working fine:   \r\n``` \r\n➜ gcloud beta emulators pubsub start --project=tokyo-rain-123 --host-port=127.0.0.1:8085\r\nExecuting: /Users/pabloruiz/Downloads/google-cloud-sdk/platform/pubsub-emulator/bin/cloud-pubsub-emulator --host=127.0.0.1 --port=8085\r\n[pubsub] This is the Google Pub/Sub fake.\r\n[pubsub] Implementation may be incomplete or differ from the real system.\r\n[pubsub] Nov 17, 2022 3:32:04 PM com.google.cloud.pubsub.testing.v1.Main main\r\n[pubsub] INFO: IAM integration is disabled. IAM policy methods and ACL checks are not supported\r\n[pubsub] SLF4J: Failed to load class \"org.slf4j.impl.StaticLoggerBinder\".\r\n[pubsub] SLF4J: Defaulting to no-operation (NOP) logger implementation\r\n[pubsub] SLF4J: See http://www.slf4j.org/codes.html#StaticLoggerBinder for further details.\r\n[pubsub] Nov 17, 2022 3:32:04 PM com.google.cloud.pubsub.testing.v1.Main main\r\n[pubsub] INFO: Server started, listening on 8085\r\n```\r\n\r\n**It is working fine using curl:**\r\n```\r\n➜ curl -X PUT http://localhost:8085/v1/projects/tokyo-rain-123/topics/topic-data1\r\n{\r\n  \"name\": \"projects/tokyo-rain-123/topics/topic-data1\"\r\n}\r\n```\r\nAlthough it is displaying this warning on the emulator:\r\n```\r\n[pubsub] INFO: Server started, listening on 8085\r\n[pubsub] Nov 17, 2022 4:00:57 PM io.gapi.emulators.netty.HttpVersionRoutingHandler channelRead\r\n[pubsub] INFO: Detected non-HTTP/2 connection.\r\n[pubsub] Nov 17, 2022 4:00:57 PM io.gapi.emulators.netty.HttpVersionRoutingHandler channelRead\r\n[pubsub] INFO: Detected HTTP/2 connection.\r\n```\r\n\r\nIf I try it with **the Python client, it just never reaches the server,** since I can't see anything in the logs. This is the Python scripts:\r\n\r\n```\r\nimport logging\r\nimport os\r\nfrom dotenv import load_dotenv\r\nfrom google.cloud import pubsub_v1\r\n\r\nload_dotenv()\r\nlogger = logging.getLogger(__name__)\r\n\r\nHOST, PROJECT_ID = os.environ.get(\"PUBSUB_EMULATOR_HOST\"), os.environ.get(\"PUBSUB_PROJECT_ID\")\r\nprint(f\"Host: {HOST}, Project ID: {PROJECT_ID}\")\r\n\r\npublisher = pubsub_v1.PublisherClient()\r\n\r\ndef list_topics(project_id):\r\n    project_path = f\"projects/{project_id}\"\r\n    all_topics = list(publisher.list_topics(\r\n        request={\"project\": project_path},\r\n        timeout=5\r\n    ))\r\n    print(f\"Found {len(all_topics)}\")\r\n    return all_topics\r\n\r\n\r\nlogger.info(\"Listing topics for project:\")\r\ntopics = list_topics(project_id=PROJECT_ID)\r\nfor topic in topics:\r\n    logger.info(topics)\r\n```\r\n\r\nwhich is just printing the correct env variables, but the client never gets a response for the rpc call. \r\n```\r\nHost: [::1]:8085, Project ID: tokyo-rain-123\r\n```\r\n\r\nAny idea why this is happening ?\r\n\r\nThanks in advance !","author":{"url":"https://github.com/PabloRR100","@type":"Person","name":"PabloRR100"},"datePublished":"2022-11-17T16:25:59.000Z","interactionStatistic":{"@type":"InteractionCounter","interactionType":"https://schema.org/CommentAction","userInteractionCount":1},"url":"https://github.com/825/python-pubsub/issues/825"}