org.apache.beam.sdk.io.googleads

Class GoogleAdsV14.SimpleRateLimitPolicy

java.lang.Object

org.apache.beam.sdk.io.googleads.GoogleAdsV14.SimpleRateLimitPolicy

All Implemented Interfaces:

GoogleAdsV14.RateLimitPolicy

Enclosing class:

GoogleAdsV14

public static class GoogleAdsV14.SimpleRateLimitPolicy
extends java.lang.Object
implements GoogleAdsV14.RateLimitPolicy

This rate limit policy wraps a RateLimiter and can be used in low volume and development use cases as a client-side rate limiting policy. This policy does not enforce a global (per pipeline or otherwise) rate limit to requests and should not be used in deployments where the Google Ads API quota is shared between multiple applications.

This policy can be used to limit requests across all GoogleAdsV14.Read or GoogleAdsV14.ReadAll transforms by defining and using a GoogleAdsV14.RateLimitPolicyFactory which holds a shared static GoogleAdsV14.SimpleRateLimitPolicy. Note that the desired rate must be divided by the expected maximum number of workers for the pipeline, otherwise the pipeline may exceed the desired rate after an upscaling event.

{@code
 public class SimpleRateLimitPolicyFactory implements GoogleAdsV14.RateLimitPolicyFactory {
   private static final GoogleAdsV14.RateLimitPolicy POLICY =
       new GoogleAdsV14.SimpleRateLimitPolicy(1.0 / 1000.0);

Constructor Summary

Constructors

Constructor and Description
SimpleRateLimitPolicy(double permitsPerSecond)
SimpleRateLimitPolicy(double permitsPerSecond, long warmupPeriod, java.util.concurrent.TimeUnit unit)

Method Summary

Modifier and Type	Method and Description
void	onBeforeRequest(java.lang.String developerToken, java.lang.String customerId, com.google.protobuf.Message request) Called before a request is sent.
void	onError(java.lang.String developerToken, java.lang.String customerId, com.google.protobuf.Message request, com.google.ads.googleads.v14.errors.GoogleAdsError error) Called after a request fails with a retryable error.
void	onSuccess(java.lang.String developerToken, java.lang.String customerId, com.google.protobuf.Message request) Called after a request succeeds.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SimpleRateLimitPolicy

public SimpleRateLimitPolicy(double permitsPerSecond)

SimpleRateLimitPolicy

public SimpleRateLimitPolicy(double permitsPerSecond,
                             long warmupPeriod,
                             java.util.concurrent.TimeUnit unit)

Method Detail

onBeforeRequest

public void onBeforeRequest(java.lang.String developerToken,
                            java.lang.String customerId,
                            com.google.protobuf.Message request)
                     throws java.lang.InterruptedException

Description copied from interface: GoogleAdsV14.RateLimitPolicy

Called before a request is sent.

Specified by:

onBeforeRequest in interface GoogleAdsV14.RateLimitPolicy

Parameters:

developerToken - The developer token used for the request.

customerId - The customer ID specified on the request.

request - Any Google Ads API request.

Throws:

java.lang.InterruptedException

onSuccess

public void onSuccess(java.lang.String developerToken,
                      java.lang.String customerId,
                      com.google.protobuf.Message request)

Description copied from interface: GoogleAdsV14.RateLimitPolicy

Called after a request succeeds.

Specified by:

onSuccess in interface GoogleAdsV14.RateLimitPolicy

Parameters:

developerToken - The developer token used for the request.

customerId - The customer ID specified on the request.

request - Any Google Ads API request.

onError

public void onError(java.lang.String developerToken,
                    java.lang.String customerId,
                    com.google.protobuf.Message request,
                    com.google.ads.googleads.v14.errors.GoogleAdsError error)

Description copied from interface: GoogleAdsV14.RateLimitPolicy

Called after a request fails with a retryable error.

Specified by:

onError in interface GoogleAdsV14.RateLimitPolicy

Parameters:

developerToken - The developer token used for the request.

customerId - The customer ID specified on the request.

request - Any Google Ads API request.

error - A retryable error.