Google Sheets Sink

The Google Sheets sink is available in the Hub.

Plugin version: 1.4.1

Writes spreadsheets to specified Google Drive directory via Google Sheets API.

Configuration

Property	Macro Enabled?	Version Introduced	Description

Property	Macro Enabled?	Version Introduced	Description
Reference Name	No		Required. Name used to uniquely identify this sink for lineage, annotating metadata, etc.
Directory Identifier	No		Required. Identifier of the destination folder. This comes after `folders/` in the URL. For example, if the URL is `https://drive.google.com/drive/folders/1dyUEebJaFnWa3Z4n0BFMVAXQ7mfUH11g?resourcekey=0-XVijrJSp3E3gkdJp20MpCQ` Then the Directory Identifier would be `1dyUEebJaFnWa3Z4n0BFMVAXQ7mfUH11g`.
Spreadsheet Name Field	Yes		Optional. Name of the schema field (should be STRING type) which will be used as name of file. Is optional. In the case it is not set Google API will use the value of Default Spreadsheet name property.
Default Spreadsheet Name	Yes		Required. Default spreadsheet file name. Is used if user doesn’t specify schema field with spreadsheet name. Default is Spreadsheet 1.
Sheet Name Field	Yes		Optional. Name of the schema field (should be STRING type) which will be used as sheet title. Is optional. In the case it is not set Google API will use the value of Default sheet name property. Default is Sheet 1
Default Sheet Name	Yes		Required. Default sheet title. Is used when user doesn’t specify schema field with sheet title.
Write Schema As First Row	Yes		Required. Toggle that defines if the sink writes out the input schema as first row of an output sheet. Default is Yes.
Authentication Type	No		Required. Type of authentication used to access Google API. OAuth2 and Service Account types are available. Make sure that: `Google Drive API` and `Google Sheets API` is enabled in the `GCP Project`. `Google Drive Folder` is shared to the service account email used with the required permission. OAuth2 client credentials can be generated on Google Cloud Credentials Page. Default is OAuth2.
Client ID	No		Optional. OAuth2 Client ID used to identify the application.
Client Secret	No		Optional. OAuth2 Client Secret used to access the authorization server.
Refresh Token	No		Optional. OAuth2 Refresh Token to acquire new access tokens.
Service Account Type	Yes	6.3.0/1.3.0	Optional. Select one of the following options: File Path. File path where the service account is located. JSON. JSON content of the service account. Make sure that the Google Drive Folder is shared with the specified service account email. To write files to a Private Google Drive, grant the `Editor` role to the specified service account. To write files to a Shared Google Drive Folder, grant the `Contributor` role to the specified service account.
Service Account File Path	Yes	6.3.0/1.3.0	Optional. Path on the local file system of the service account key used for authorization. Can be set to 'auto-detect' when running on a Dataproc cluster which needs to be created with the following scopes: https://www.googleapis.com/auth/drive https://www.googleapis.com/auth/spreadsheets When running on other clusters, the file must be present on every node in the cluster. Default is `auto-detect`.
Service Account JSON	Yes	1.4.0	Optional. Contents of the service account JSON file. Service Account JSON can be generated on Google Cloud Service Account page.
Threads Number	Yes		Required. Number of threads which send batched API requests. The greater value allows to process records quickly, but requires extended Google Sheets API quota. Default is 5.
Maximal Buffer Size	Yes		Required. Maximal size in records of the batch API request. The greater value allows to reduce the number of API requests, but causes increase of their size. Default is 50.
Records Queue Length	Yes		Required. Size of the queue used to receive records and for onwards grouping of them to batched API requests. With the greater value it is more likely that the sink will group received records in the batches of maximal size. Also greater value leads to more memory consumption. Default is 500.
Maximum Flush Interval	Yes		Required. Number of seconds between the sink tries to get batched requests from the records queue and send them to threads for sending to Sheets API. Default is 10.
Flush Execution Timeout	Yes		Required. Timeout for single thread to process the batched API request. Be careful, the number of retries and maximal retry time also should be taken into account. Default is 500.
Minimal Page Extension Size	Yes		Required. Minimal size of sheet extension when default sheet size is exceeded. Default is 1000.
Merge Data Cells	Yes		Required. Toggle that defines if the sink merges data cells created as result of input arrays flattering. Default is No.
Skip spreadsheet/sheet name fields	Yes		Required. Toggle that defines if the sink skips spreadsheet/sheet name fields during structure record transforming. Default is No.

Steps to Generate OAuth2 Credentials

Create credentials for the Client ID and Client Secret properties here.
On the Create OAuth client ID page, under Authorized redirect URIs, specify a URI of http://localhost:8080. This is just to generate the refresh token.
Click Create. The OAuth client is created. For more information, see this doc.
Copy the Client ID and Client Secret to the plugin properties.
To get the Refresh Token, follow these steps:
1. Authenticate and authorize with the Google Auth server to get an authorization code.
2. Use that authorization code with the Google Token server to get a refresh token that the plugin will use to get future access tokens.
To get the authorization code, you can copy the URL below, change to use your client_id, and then open that URL in a browser window.
https://accounts.google.com/o/oauth2/v2/auth? scope=https%3A//www.googleapis.com/auth/drive%20https://www.googleapis.com/auth/spreadsheets& access_type=offline& include_granted_scopes=true& response_type=code& state=state_parameter_passthrough_value& redirect_uri=http%3A//localhost:8080& client_id=199375159079-st8toco9pfu1qi5b45fkj59unc5th2v1.apps.googleusercontent.com
This will prompt you to login, authorize this client for specified scopes, and then redirect you to http://localhost:8080. It will look like an error page, but notice that the URL of the error page redirected to include the code. In a normal web application, that is how the authorization code is returned to the requesting web application.
For example, URL of the page will be something like
http://localhost:8080/?state=state_parameter_passthrough_value&code=4/0AX4XfWi6PsiJiPO4MjltrcD6uoRgwci-HX16aL1-Ax-tgqYgC47NnjtCCKRoVzv46m8aJw&scope=https://www.googleapis.com/auth/drive
Here, code=4/0AX4XfWi6PsiJiPO4MjltrcD6uoRgwci-HX16aL1-Ax-tgqYgC47NnjtCCKRoVzv46m8aJw.
Note: If you see an error like this Authorization Error — Error 400: admin_policy_enforced, then the GCP User’s organization has a policy that restricts you from using Client IDs for third party products. In that case, they’ll need to get that restriction lifted, or use a different GCP user in a different org.
With that authorization code, you can now call the Google Token server to get the access token and the refresh token in the response. Set the code, client_id, and client_secret in the curl command below and run it in a Cloud Shell terminal.
Now, you will have your refresh_token, which is the last OAuth 2.0 property that the Google Sheets Batch Sink needs to authorize with the Google Drive and Google Sheets API.