diff --git a/scouter/activities/pydruid.py b/scouter/activities/pydruid.py index e3f1750..f19e4bb 100644 --- a/scouter/activities/pydruid.py +++ b/scouter/activities/pydruid.py @@ -19,7 +19,7 @@ class Druid(BaseActivity): self.host = host self.port = port - self.engine = create_engine( + self.druid_engine = create_engine( f'druid://{self.host}:{self.port}/druid/v2/sql/') logger.info( f"Druid client initialized with host: {self.host}, port: {self.port}") @@ -51,10 +51,10 @@ class Druid(BaseActivity): f"Loading data from Druid: {datasource} with query: {query}" ) - places = Table(datasource, MetaData(), autoload_with=self.engine) + places = Table(datasource, MetaData(), autoload_with=self.druid_engine) stmt = select(places).where(text(query)) - result = pd.read_sql(stmt, self.engine) + result = pd.read_sql(stmt, self.druid_engine) result["inserted_at"] = pd.to_datetime(result["__time"]).dt.strftime( "%Y-%m-%d %H:%M:%S.%f") diff --git a/values.yaml b/values.yaml index 884ccf7..6686b55 100644 --- a/values.yaml +++ b/values.yaml @@ -185,7 +185,7 @@ env: - name: DRUID_HOST value: "druid-router.druid.svc.cluster.local" - name: DRUID_PORT - value: "8081" + value: "8888" ssh: enabled: true