diff --git a/src/metadata/fetcher.py b/src/metadata/fetcher.py index 8066580..3bdbb6e 100644 --- a/src/metadata/fetcher.py +++ b/src/metadata/fetcher.py @@ -138,10 +138,11 @@ def save_metadata(metadata): # Escape special characters in name for Influx Line Protocol name = name.replace(' ', '\\ ').replace(',', '\\,').replace('"', '\\"') - line = f'metadata,isin={isin} name="{name}",country="{country}",continent="{continent}",sector="{sector}"' + # QuestDB requires a newline at the end of the line protocol + line = f'metadata,isin={isin} name="{name}",country="{country}",continent="{continent}",sector="{sector}"\n' try: - response = requests.post(f"http://{DB_HOST}:9000/write", data=line + "\n", auth=DB_AUTH) + response = requests.post(f"http://{DB_HOST}:9000/write", data=line, auth=DB_AUTH) if response.status_code not in [200, 204]: logger.error(f"Error saving metadata: {response.text}") except Exception as e: