monika_rajput
05/06/2022, 8:34 PM"""Stream type classes for tap-cj."""
from pathlib import Path
from typing import Any, Dict, Optional, Union, List, Iterable
# TODO: Delete this is if not using json files for schema definition
SCHEMAS_DIR = Path(__file__).parent / Path("./schemas")
yesterday = '2022-04-25'
today = '2022-05-03'
class advertiserCommissions(cjStream):
"""Define custom stream."""
name = "advertiserCommissions"
# Optionally, ou may also use `schema_filepath` in place of `schema`:
schema_filepath = SCHEMAS_DIR / "advertiserCommissions.graphql"
#primary_keys = ["id"]
replication_key = None
query = "{ advertiser(forAdvertisers: [\"11111\"], sincePostingDate:\""+yesterday+"T08:00:00Z\",beforePostingDate:\""+today+"T08:00:00Z\"){count payload }}"
advertiser.graphql
type AdvertiserCommissions {
count: Int
payloadComplete: Boolean
}
type Root {
advertiserCommissions: AdvertiserCommissions
}
When i am running the meltano elt tap-z target-csv
, it's throwing Cannot start extractor: Catalog discovery failed:
I must doing wrong something , If someone can help here that would be great.
Thank you.monika_rajput
05/06/2022, 8:46 PM