Eventarc Quickstart Brushup (#4762)

## Eventarc Quickstart Brushup

- Region tag fixes

eventarc/audit-storage/Dockerfile

@@ -12,7 +12,7 @@
 # See the License for the specific language governing permissions and
 # limitations under the License.
 
-# [START run_events_gcs_dockerfile]
+# [START eventarc_gcs_dockerfile]
 
 # Use the official Python image.
 # https://hub.docker.com/_/python
@@ -38,4 +38,4 @@ COPY . ./
 # For environments with multiple CPU cores, increase the number of workers
 # to be equal to the cores available.
 CMD exec gunicorn --bind :$PORT --workers 1 --threads 8 --timeout 0 main:app
-# [END run_events_gcs_dockerfile]
+# [END eventarc_gcs_dockerfile]

eventarc/audit-storage/README.md

@@ -1,4 +1,4 @@
-# Cloud Eventarc – GCS tutorial
+# Cloud Eventarc - Cloud Storage via Audit Logs tutorial
 
 This sample shows how to create a service that processes GCS using [the CloudEvents SDK](https://github.com/cloudevents/sdk-python).
 

eventarc/audit-storage/main.py

@@ -11,7 +11,8 @@
 # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 # See the License for the specific language governing permissions and
 # limitations under the License.
-# [START run_events_gcs_handler]
+
+# [START eventarc_gcs_server]
 import os
 
 import cloudevents.exceptions as cloud_exceptions
@@ -22,8 +23,10 @@
 
 required_fields = ['Ce-Id', 'Ce-Source', 'Ce-Type', 'Ce-Specversion']
 app = Flask(__name__)
+# [END eventarc_gcs_server]
 
 
+# [START eventarc_gcs_handler]
 @app.route('/', methods=['POST'])
 def index():
     # Create CloudEvent from HTTP headers and body
@@ -49,10 +52,10 @@ def index():
 
     print(f"Detected change in GCS bucket: {event['subject']}")
     return (f"Detected change in GCS bucket: {event['subject']}", 200)
-# [END run_events_gcs_handler]
+# [END eventarc_gcs_handler]
 
 
-# [START run_events_gcs_server]
+# [START eventarc_gcs_server]
 if __name__ == "__main__":
     app.run(debug=True, host='0.0.0.0', port=int(os.environ.get('PORT', 8080)))
-# [END run_events_gcs_server]
+# [END eventarc_gcs_server]

eventarc/pubsub/Dockerfile

@@ -12,7 +12,7 @@
 # See the License for the specific language governing permissions and
 # limitations under the License.
 
-# [START run_events_pubsub_dockerfile]
+# [START eventarc_pubsub_dockerfile]
 
 # Use the official Python image.
 # https://hub.docker.com/_/python
@@ -38,4 +38,4 @@ COPY . ./
 # For environments with multiple CPU cores, increase the number of workers
 # to be equal to the cores available.
 CMD exec gunicorn --bind :$PORT --workers 1 --threads 8 --timeout 0 main:app
-# [END run_events_pubsub_dockerfile]
+# [END eventarc_pubsub_dockerfile]

eventarc/pubsub/main.py

@@ -12,7 +12,7 @@
 # See the License for the specific language governing permissions and
 # limitations under the License.
 
-# [START run_events_pubsub_server_setup]
+# [START eventarc_pubsub_server]
 import base64
 
 import os
@@ -26,10 +26,10 @@
 required_fields = ['Ce-Id', 'Ce-Source', 'Ce-Type', 'Ce-Specversion']
 
 app = Flask(__name__)
-# [END run_events_pubsub_server_setup]
+# [END eventarc_pubsub_server]
 
 
-# [START run_events_pubsub_handler]
+# [START eventarc_pubsub_handler]
 @app.route('/', methods=['POST'])
 def index():
     # Create CloudEvent from HTTP headers and body
@@ -69,10 +69,10 @@ def index():
     resp = f"Hello, {name}! ID: {event['id']}"
     print(resp)
     return (resp, 200)
-# [END run_events_pubsub_handler]
+# [END eventarc_pubsub_handler]
 
 
-# [START run_events_pubsub_server]
+# [START eventarc_pubsub_server]
 if __name__ == "__main__":
     app.run(debug=True, host='0.0.0.0', port=int(os.environ.get('PORT', 8080)))
-# [END run_events_pubsub_server]
+# [END eventarc_pubsub_server]