diff --git a/GoogleCloud.py b/GoogleCloud.py new file mode 100644 index 0000000..5ad511e --- /dev/null +++ b/GoogleCloud.py @@ -0,0 +1,73 @@ +#!/usr/bin/env python +# coding: utf-8 + +# In[1]: + + +from google.cloud import pubsub_v1 + + +# In[2]: + + +# Set the project ID and topic name +project_id = "sloetjes-project1" +topic_name = "sloetjes-project1" +subscription_name = "sloetjes-final-project1" + + +# In[3]: + + +# Create a publisher client +publisher = pubsub_v1.PublisherClient() + + +# In[4]: + + +# Create the fully qualified topic path +topic_path = publisher.topic_path(project_id, topic_name) + + +# In[5]: + + +# Create the Pub/Sub topic +topic = publisher.create_topic(name = topic_path) + + +# In[ ]: + + +# Print the topic name +print(f"Topic created: {topic.name}") + + +# In[ ]: + + +# Create the subscription if it doesn't exist +subscription_path = subscriber.subscription_path(project_id, subscription_name) +topic_path = publisher.topic_path(project_id, topic_name) + +# Publish a message to the topic +message = "Hello, World!" +data = message.encode("utf-8") +publisher.publish(topic_path, data=data) +print(f"Message published: {message}") + +# Pull the message from the subscription +response = subscriber.pull(subscription_path, max_messages=1) +for received_message in response.received_messages: + print(f"Received message: {received_message.message.data}") + + # Acknowledge the message + subscriber.acknowledge(subscription_path, [received_message.ack_id]) + + +# In[ ]: + + + + diff --git a/Gunicorn.png b/Gunicorn.png deleted file mode 100644 index 8f7844f..0000000 Binary files a/Gunicorn.png and /dev/null differ