Issues Writing from Azure Function to Google Pub Sub

Asked Mar 08 '22 at 14:28

Active Mar 09 '22 at 03:01

Viewed 205 times

I want to write messages from a service bus queue to a topic in GCP Pub Sub. I hve a azure function that is triggered by incoming queue message.

I then write the message to the Pub Sub Topic. I understand there is more to do to access GCP resources.

What I'm first failing at is even getting azure to recognise the google.cloud module.

Can anyone help with this?

FailureException: ModuleNotFoundError: No module named 'google.cloud'.

rest of my code for reference...

import logging
import json
import azure.functions as func
from google.cloud import pubsub_v1
from google.oauth2 import service_account

CREDENTIALS = service_account.Credentials.from_service_account_file(
    './service_account.json')


PUBLISHER = pubsub_v1.PublisherClient(credentials=CREDENTIALS)

PROJECT_ID = 'polestar-poc'


def publish_to_gcp(topic, msg):
    PUBLISHER.create_topic(PROJECT_ID, name=topic)
    PUBLISHER.publish(topic, msg)


def main(msg: func.ServiceBusMessage):
    data = json.loads(msg.get_body())
    topic_name = (data['topic'])
    publish_to_gcp(topic_name, data)

asked Mar 08 '22 at 14:28

Harvey

have you added the dependent GCP module /package names in your `requirements.txt` file ? – Anand Sowmithiran Mar 08 '22 at 14:34
yes I have google-cloud-pubsub in my requirements.txt – Harvey Mar 08 '22 at 14:42
Can you try by changing `from google.cloud import pubsub_v1` to `from google import pubsub_v1`? – Gaurav Mantri Mar 08 '22 at 14:48
This just results in pubsub_v1 not being recognised – Harvey Mar 08 '22 at 15:03

Issues Writing from Azure Function to Google Pub Sub

0 Answers0