Skip to content

Merging code for 'Utilizing Cloud Logging and Cloud Run to create Event Driven Data Pipelines'#283

Open
ghost wants to merge 17 commits intoGoogleCloudPlatform:masterfrom
yrvine:master
Open

Merging code for 'Utilizing Cloud Logging and Cloud Run to create Event Driven Data Pipelines'#283
ghost wants to merge 17 commits intoGoogleCloudPlatform:masterfrom
yrvine:master

Conversation

@ghost
Copy link

@ghost ghost commented Feb 14, 2022

Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Remove this entire file

@@ -0,0 +1,64 @@
/*
Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Remove this file

Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

My mistake; I see this is needed to map the message into a JSON object

Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

This file would be better named: BigQueryMetadataAuditLog

Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

If you're going to have a class like this, you should have it also store bq job notifications which come in through pubsub.

Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Why parse bq job notifications differently than gcs notifications? Unify with one parser that handles both

Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Remove if this is not needed

Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

This does not mean the job was successful, only that that job completed.
You must check the status of the job as follows:

if(job.isDone() && job.getStatus().getError() == null)

Source: https://googleapis.dev/java/google-cloud-bigquery/latest/com/google/cloud/bigquery/BigQueryError.html

yrvine-g and others added 8 commits February 16, 2022 18:44
Co-authored-by: Daniel De Leo <danieldeleo@users.noreply.github.com>
Co-authored-by: Daniel De Leo <danieldeleo@users.noreply.github.com>
Co-authored-by: Daniel De Leo <danieldeleo@users.noreply.github.com>
…le/cloudrun/BQAccessor.java

Co-authored-by: Daniel De Leo <danieldeleo@users.noreply.github.com>
…le/cloudrun/GCSAccessor.java

Co-authored-by: Daniel De Leo <danieldeleo@users.noreply.github.com>
Co-authored-by: Daniel De Leo <danieldeleo@users.noreply.github.com>
Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

remove unused import

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants

Comments