feat: init eventarc quickstarts (GoogleCloudPlatform#4710)

* feat: init eventarc quickstarts

Signed-off-by: Grant Timmerman 

* fix: update readmes and gh owners

Signed-off-by: Grant Timmerman 

* fix: fix gcs cal assertion

Signed-off-by: Grant Timmerman 

* fix: readme nits

Signed-off-by: Grant Timmerman 

* docs: update eventarc readme formatting

Author: grant

.github/CODEOWNERS

@@ -34,6 +34,7 @@
 /dns/**/*.py                           @michaelawyu @GoogleCloudPlatform/python-samples-owners
 /endpoints/**/*.py                     @GoogleCloudPlatform/python-samples-owners
 /error_reporting/**/*.py               @GoogleCloudPlatform/python-samples-owners
+/eventarc/**/*.py                      @averikitsch @grant @GoogleCloudPlatform/python-samples-owners
 /firestore/**/*.py                     @GoogleCloudPlatform/firestore-dpe @GoogleCloudPlatform/python-samples-owners
 /functions/**/*.py                     @ace-n @grant @GoogleCloudPlatform/python-samples-owners
 /healthcare/**/*.py                    @noerog @GoogleCloudPlatform/python-samples-owners

eventarc/README.md

@@ -0,0 +1,114 @@
+# Google Cloud Eventarc Python Samples
+
+[![Open in Cloud Shell][shell_img]][shell_link]
+
+[shell_img]: http://gstatic.com/cloudssh/images/open-btn.png
+[shell_link]: https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/GoogleCloudPlatform/python-docs-samples&page=editor&open_in_editor=blog/README.md
+
+This directory contains samples for Google Cloud Eventarc.
+
+## Samples
+
+|           Sample                |        Description       |     Deploy    |
+| ------------------------------- | ------------------------ | ------------- |
+|[Events – Pub/Sub][events_pubsub]  | Event-driven service with Events for Cloud Run for Pub/Sub    |      -        |
+|[Anthos Events – Pub/Sub][anthos_events_pubsub]  | Event-driven service with Events for Cloud Run on Anthos for Pub/Sub  |      -        |
+|[Events – GCS][events_storage]  | Event-driven service with Events for Cloud Run for GCS    |      -        |
+|[Anthos Events – GCS][anthos_events_storage]  | Event-driven service with Events for Cloud Run on Anthos for GCS  |      -        |
+
+For more Cloud Run samples beyond Python, see the main list in the [Cloud Run Samples repository](https://github.com/GoogleCloudPlatform/cloud-run-samples).
+
+## Setup
+
+1. [Set up for Cloud Run development](https://cloud.google.com/run/docs/setup)
+
+2. Clone this repository:
+
+    ```
+    git clone https://github.com/GoogleCloudPlatform/python-docs-samples.git
+    ```
+
+    Note: Some samples in the list above are hosted in other repositories. They are noted with the symbol "➥".
+
+
+## How to run a sample locally
+
+1. [Install docker locally](https://docs.docker.com/install/)
+
+2. [Build the sample container](https://cloud.google.com/run/docs/building/containers#building_locally_and_pushing_using_docker):
+
+    ```
+    export SAMPLE=
+    cd $SAMPLE
+    docker build --tag $SAMPLE .
+    ```
+
+3. [Run containers locally](https://cloud.google.com/run/docs/testing/local)
+
+    With the built container:
+
+    ```
+    PORT=8080 && docker run --rm -p 8080:${PORT} -e PORT=${PORT} $SAMPLE
+    ```
+
+    Overriding the built container with local code:
+
+    ```
+    PORT=8080 && docker run --rm \
+        -p 8080:${PORT} -e PORT=${PORT} \
+        -v $PWD:/app $SAMPLE
+    ```
+
+    Injecting your service account key for access to GCP services:
+
+    ```
+    # Set the name of the service account key within the container
+    export SA_KEY_NAME=my-key-name-123
+
+    PORT=8080 && docker run --rm \
+        -p 8080:${PORT} \
+        -e PORT=${PORT} \
+        -e GOOGLE_APPLICATION_CREDENTIALS=/tmp/keys/${SA_KEY_NAME}.json \
+        -v $GOOGLE_APPLICATION_CREDENTIALS:/tmp/keys/${SA_KEY_NAME}.json:ro \
+        -v $PWD:/app $SAMPLE
+    ```
+
+    * Use the --volume (-v) flag to inject the credential file into the container
+      (assumes you have already set your `GOOGLE_APPLICATION_CREDENTIALS`
+      environment variable on your machine)
+
+    * Use the --environment (-e) flag to set the `GOOGLE_APPLICATION_CREDENTIALS`
+      variable inside the container
+
+    Learn more about [testing your container image locally.][testing]
+
+## Deploying a Cloud Run service
+
+1. Set an environment variable with your GCP Project ID
+    ```
+    export GOOGLE_CLOUD_PROJECT=
+    ```
+
+1. Submit a build using Google Cloud Build
+    ```
+    gcloud builds submit --tag gcr.io/${GOOGLE_CLOUD_PROJECT}/${SAMPLE}
+    ```
+
+1. Deploy to Cloud Run
+    ```
+    gcloud run deploy $SAMPLE --image gcr.io/${GOOGLE_CLOUD_PROJECT}/${SAMPLE}
+    ```
+
+Choose a particular sample for information about triggering the service with an event.
+
+See [Building containers][run_build] and [Deploying container images][run_deploy]
+for more information.
+
+[run_docs]: https://cloud.google.com/run/docs/
+[run_build]: https://cloud.google.com/run/docs/building/containers
+[run_deploy]: https://cloud.google.com/run/docs/deploying
+[events_pubsub]: pubsub/README.md
+[anthos_events_pubsub]: pubsub/anthos.md
+[events_storage]: audit-storage/README.md
+[anthos_events_storage]: audit-storage/anthos.md
+[testing]: https://cloud.google.com/run/docs/testing/local#running_locally_using_docker_with_access_to_services

run/events-storage/Dockerfile renamed to eventarc/audit-storage/Dockerfile

@@ -0,0 +1,68 @@
+# Cloud Eventarc – GCS tutorial
+
+This sample shows how to create a service that processes GCS using [the CloudEvents SDK](https://github.com/cloudevents/sdk-python).
+
+## Setup
+
+Configure environment variables:
+
+```sh
+MY_RUN_SERVICE=gcs-service
+MY_RUN_CONTAINER=gcs-container
+MY_GCS_BUCKET=gcs-bucket # Must be globally unique.
+```
+
+## Quickstart
+
+Deploy your Cloud Run service:
+
+```sh
+gcloud builds submit \
+  --tag gcr.io/$(gcloud config get-value project)/$MY_RUN_CONTAINER
+gcloud run deploy $MY_RUN_SERVICE \
+  --image gcr.io/$(gcloud config get-value project)/$MY_RUN_CONTAINER \
+  --platform managed
+```
+
+Create a _single region_ Cloud Storage bucket:
+
+```sh
+gsutil mb -p $(gcloud config get-value project) \
+  -l us-central1 \
+  gs://"$MY_GCS_BUCKET"
+```
+
+Create Cloud Storage trigger:
+
+```sh
+gcloud beta eventarc triggers create my-gcs-trigger \
+  --destination-run-service $MY_RUN_SERVICE  \
+  --matching-criteria type=google.cloud.audit.log.v1.written \
+  --matching-criteria methodName=storage.buckets.update \
+  --matching-criteria serviceName=storage.googleapis.com \
+  --matching-criteria resourceName=projects/_/buckets/"$MY_GCS_BUCKET"
+```
+
+## Test
+
+Test your Cloud Run service by creating a GCS event:
+
+```sh
+gsutil defstorageclass set STANDARD gs://$MY_GCS_BUCKET
+```
+
+Observe the Cloud Run service printing upon receiving an event in Cloud Logging:
+
+```sh
+gcloud logging read "resource.type=cloud_run_revision AND \
+  resource.labels.service_name=$MY_RUN_SERVICE" \
+  --project $(gcloud config get-value project) \
+  --limit 30 \
+  --format 'value(textPayload)'
+```
+
+One of the logs you'll see shows the Run service confirming the event was received:
+
+```
+GCS CloudEvent type: storage.googleapis.com/projects/_/buckets/gcs-bucket
+```

eventarc/audit-storage/README.md

@@ -47,8 +47,8 @@ def index():
         print(errmsg)
         return errmsg, 400
 
-    print(f"GCS CloudEvent type: {event['subject']}")
-    return (f"GCS CloudEvent type: {event['subject']}", 200)
+    print(f"Detected change in GCS bucket: {event['subject']}")
+    return (f"Detected change in GCS bucket: {event['subject']}", 200)
 # [END run_events_gcs_handler]
 
 

run/events-storage/anthos.md renamed to eventarc/audit-storage/anthos.md

@@ -42,7 +42,7 @@ def test_endpoint(client, capsys):
     assert r.status_code == 200
 
     out, _ = capsys.readouterr()
-    assert f"GCS CloudEvent type: {test_headers['Ce-Subject']}" in out
+    assert f"Detected change in GCS bucket: {test_headers['Ce-Subject']}" in out
 
 
 def test_missing_subject(client, capsys):

run/events-storage/main.py renamed to eventarc/audit-storage/main.py

@@ -0,0 +1,47 @@
+# Cloud Eventarc – Pub/Sub tutorial
+
+This sample shows how to create a service that processes Pub/Sub events using 
+[the CloudEvents SDK](https://github.com/cloudevents/sdk-python).
+
+## Quickstart
+
+Deploy your Cloud Run service:
+
+```sh
+gcloud builds submit \
+  --tag gcr.io/$(gcloud config get-value project)/eventarc-pubsub
+gcloud run deploy eventarc-pubsub \
+  --image gcr.io/$(gcloud config get-value project)/eventarc-pubsub \
+  --platform managed
+```
+
+Create a Cloud Eventarc trigger, which will also create a Pub/Sub topic:
+
+```sh
+gcloud beta eventarc triggers create pubsub-trigger \
+  --destination-run-service eventarc-pubsub \
+  --matching-criteria "type=google.cloud.pubsub.topic.v1.messagePublished"
+```
+
+## Test
+
+Test your Cloud Run service by getting the created topic, and publishing a message to that topic:
+
+```sh
+TOPIC=$(gcloud beta eventarc triggers describe pubsub-trigger \
+--format="value(transport.pubsub.topic)")
+
+echo "Listening to events on topic: $TOPIC"
+
+gcloud pubsub topics publish $TOPIC --message="Events"
+```
+
+You may observe the Run service receiving an event in Cloud Logging:
+
+```sh
+gcloud logging read "resource.type=cloud_run_revision AND \
+resource.labels.service_name=eventarc-pubsub" \
+  --project $(gcloud config get-value project) \
+  --limit 10 \
+  --format 'value(textPayload)'
+```

run/events-storage/main_test.py renamed to eventarc/audit-storage/main_test.py

@@ -15,10 +15,6 @@ This directory contains samples for [Google Cloud Run](https://cloud.run). [Clou
 |[Cloud Pub/Sub][pubsub] | Handling Pub/Sub push messages | [<img src="https://storage.googleapis.com/cloudrun/button.svg" alt="Run on Google Cloud" height="30">][run_button_pubsub] |
 |[Cloud SQL (MySQL)][mysql]        | Use MySQL with Cloud Run    |      -        |
 |[Cloud SQL (Postgres)][postgres]  | Use Postgres with Cloud Run |      -        |
-|[Events – Pub/Sub][events_pubsub]  | Event-driven service with Events for Cloud Run for Pub/Sub    |      -        |
-|[Anthos Events – Pub/Sub][anthos_events_pubsub]  | Event-driven service with Events for Cloud Run on Anthos for Pub/Sub  |      -        |
-|[Events – GCS][events_storage]  | Event-driven service with Events for Cloud Run for GCS    |      -        |
-|[Anthos Events – GCS][anthos_events_storage]  | Event-driven service with Events for Cloud Run on Anthos for GCS  |      -        |
 
 For more Cloud Run samples beyond Python, see the main list in the [Cloud Run Samples repository](https://github.com/GoogleCloudPlatform/cloud-run-samples).
 
@@ -113,10 +109,6 @@ for more information.
 [pubsub]: pubsub/
 [mysql]: ../cloud-sql/mysql/sqlalchemy
 [postgres]: ../cloud-sql/postgres/sqlalchemy
-[events_pubsub]: events-pubsub/
-[anthos_events_pubsub]: events-pubsub/anthos.md
-[events_storage]: events-storage/
-[anthos_events_storage]: events-storage/anthos.md
 [run_button_helloworld]: https://deploy.cloud.run/?git_repo=https://github.com/knative/docs&dir=docs/serving/samples/hello-world/helloworld-python
 [run_button_pubsub]: https://deploy.cloud.run/?git_repo=https://github.com/GoogleCloudPlatform/python-docs-samples&dir=run/pubsub
 [testing]: https://cloud.google.com/run/docs/testing/local#running_locally_using_docker_with_access_to_services