add campaign label stream

Author: edgao

airbyte-integrations/connectors/source-google-ads/source_google_ads/google_ads.py

@@ -16,6 +16,7 @@
  "ad_group_ads": "ad_group_ad",
  "ad_groups": "ad_group",
  "campaigns": "campaign",
+ "campaign_labels": "campaign_label",
  "account_performance_report": "customer",
  "ad_group_ad_report": "ad_group_ad",
  "display_keyword_performance_report": "display_keyword_view",

airbyte-integrations/connectors/source-google-ads/source_google_ads/schemas/campaign_labels.json

@@ -0,0 +1,18 @@
+{
+ "$schema": "http://json-schema.org/draft-07/schema#",
+ "type": "object",
+ "properties": {
+ "campaign.id": {
+ "type": ["null", "integer"]
+ },
+ "label.id": {
+ "type": ["null", "integer"]
+ },
+ "label.name": {
+ "type": ["null", "integer"]
+ },
+ "campaign_label.resource_name": {
+ "type": ["null", "string"]
+ }
+ }
+}

airbyte-integrations/connectors/source-google-ads/source_google_ads/source.py

@@ -21,6 +21,7 @@
  AdGroupAdReport,
  AdGroupAds,
  AdGroups,
+ CampaignLabels,
  Campaigns,
  ClickView,
  DisplayKeywordPerformanceReport,
@@ -115,6 +116,7 @@ def streams(self, config: Mapping[str, Any]) -> List[Stream]:
  AdGroups(**incremental_stream_config),
  Accounts(**incremental_stream_config),
  Campaigns(**incremental_stream_config),
+ CampaignLabels(google_api),
  ClickView(**incremental_stream_config),
  ]
 

airbyte-integrations/connectors/source-google-ads/source_google_ads/streams.py

@@ -3,7 +3,7 @@
 #
 
 from abc import ABC
-from typing import Any, Iterable, List, Mapping, MutableMapping, Optional, Tuple
+from typing import Any, Iterable, List, Mapping, MutableMapping, Optional, Tuple, Union
 
 import pendulum
 from airbyte_cdk.models import SyncMode
@@ -111,7 +111,9 @@ class IncrementalGoogleAdsStream(GoogleAdsStream, ABC):
  primary_key = None
  range_days = 15 # date range is set to 15 days, because for conversion_window_days default value is 14. Range less than 15 days will break the integration tests.
 
- def __init__(self, start_date: str, conversion_window_days: int, time_zone: [pendulum.timezone, str], end_date: str = None, **kwargs):
+ def __init__(
+ self, start_date: str, conversion_window_days: int, time_zone: Union[pendulum.timezone, str], end_date: str = None, **kwargs
+ ):
  self.conversion_window_days = conversion_window_days
  self._start_date = start_date
  self.time_zone = time_zone
@@ -231,6 +233,17 @@ class Campaigns(IncrementalGoogleAdsStream):
  primary_key = ["campaign.id", "segments.date"]
 
 
+class CampaignLabels(GoogleAdsStream):
+ """
+ Campaign labels stream: https://developers.google.com/google-ads/api/fields/v8/campaign_label
+ """
+
+ def __init__(self, api):
+ super().__init__(api)
+
+ primary_key = ["campaign_label.resource_name"]
+
+
 class AdGroups(IncrementalGoogleAdsStream):
  """
  AdGroups stream: https://developers.google.com/google-ads/api/fields/v8/ad_group

airbyte-integrations/connectors/source-google-ads/unit_tests/test_source.py

@@ -51,7 +51,7 @@ def test_chunk_date_range():
 def test_streams_count(config):
  source = SourceGoogleAds()
  streams = source.streams(config)
- expected_streams_number = 16
+ expected_streams_number = 17
  assert len(streams) == expected_streams_number