status-im/airbyte-custom-connector
2
0
Fork 0
mirror of https://github.com/status-im/airbyte-custom-connector.git synced 2025-02-17 03:16:36 +00:00
Code Issues Packages Projects Releases Wiki Activity

source-crypto-market-extractor: Fixing coin name missing

Browse Source 
Signed-off-by: Alexis Pentori <alexis@status.im>
This commit is contained in:
Alexis Pentori 2024-01-19 08:08:56 +01:00
parent ebf65b1b78
commit 8ec37e115b
No known key found for this signature in database
GPG Key ID: 65250D2801E47A10
1 changed files with 2 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
source-crypto-market-extractor/source_crypto_market_extractor/source.py
View File

@ -16,7 +16,6 @@ logger = logging.getLogger("airbyte")
class CoinPrice(HttpStream):
url_base = 'https://api.coingecko.com/api/v3/coins/'
primary_key = None
def __init__(self, coins: List['str'], **kwargs):
@ -46,7 +45,7 @@ class CoinPrice(HttpStream):
logger.info("Parsing Coin Gecko data for %s", coin)
market_chart = response.json()
yield {
"coin": coin,
"name": coin,
"date": datetime.today().strftime('%Y%m%d_%H%M'),
# The first value of the prices objects is weird
"price": market_chart['prices'][1][1],
@ -55,7 +54,7 @@ class CoinPrice(HttpStream):
# Source
class SourceCryptoMarketExtractor(AbstractSource):
def check_connection(self, logger, config) -> Tuple[bool, any]:
return True, None
return True, None
def streams(self, config: Mapping[str, Any]) -> List[Stream]:
logger.info('Config : %s', config['coins'])