Create cloud function and pubsub topics

create-cf-pubsub.py

REGION = "your-cloud-function-region"
TOPIC_NAME = "sensor-data-processing"
SOURCE_URI = "cloud-function-file-directory"
ENTRY_POINT = "detect_anomaly"

# create to pub/sub topic
gcloud pubsub topics create TOPIC_NAME

# Create cloud function
gcloud functions deploy sensor-data-processing \
--runtime=python310 \
--region=REGION \
--source=SOURCE_URI \
--entry-point=ENTRY_POINT \
--trigger-topic=TOPIC_NAME \
--allow-unauthenticated

# Create query payload
query_payload = {
               "attributes": {
                   "time": "1664826843", 
                   "temperature": "34.18",
                   "light": "23",
                   "h2_raw": "1040",
                   "humidity": "26",
                   "dataset": "sensor-data",
                   "metric": ["temp"],
                   "forecast_history": "43000s",
                   "granularity": "600s",
                   "noise_threshold": "100.0",
                   "anomaly_threshold": "1.0"
               }
            }
    
# Publish message to cloud function
gcloud pubsub topics publish TOPIC_NAME --message=query_payload