src/modules/timestream_telemetry/lambda_function/udq_data_reader.py [54:63]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        if property_filter: 
            sample_query = f"""SELECT TelemetryAssetId, measure_name, time, measure_value::double, measure_value::varchar FROM CookieFactoryTelemetry.Telemetry  WHERE time > from_iso8601_timestamp('2021-10-18T21:42:58') AND time <= from_iso8601_timestamp('2021-10-18T21:43:35') AND TelemetryAssetType = 'test' AND TelemetryAssetId = 'test' AND measure_name = 'alarm_status' AND measure_value::varchar {property_filter['operator']} 'abc'  ORDER BY time ASC"""
        else:
            sample_query = """SELECT TelemetryAssetId, measure_name, time, measure_value::double, measure_value::varchar FROM CookieFactoryTelemetry.Telemetry  WHERE time > from_iso8601_timestamp('2021-10-18T21:42:58') AND time <= from_iso8601_timestamp('2021-10-18T21:43:35') AND TelemetryAssetType = 'test' AND TelemetryAssetId = 'test' AND measure_name = 'alarm_status'   ORDER BY time ASC"""

        query_string = f"SELECT TelemetryAssetId, measure_name, time, measure_value::double, measure_value::varchar" \
            f" FROM {self.database_name}.{self.table_name} " \
            f" WHERE time > from_iso8601_timestamp('{request.start_datetime.isoformat()}')" \
            f" AND time <= from_iso8601_timestamp('{request.end_datetime.isoformat()}')" \
            f" AND TelemetryAssetType = '{telemetry_asset_type}'" \
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



src/modules/timestream_telemetry/lambda_function/udq_data_reader.py [87:96]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        if property_filter: 
            sample_query = f"""SELECT TelemetryAssetId, measure_name, time, measure_value::double, measure_value::varchar FROM CookieFactoryTelemetry.Telemetry  WHERE time > from_iso8601_timestamp('2021-10-18T21:42:58') AND time <= from_iso8601_timestamp('2021-10-18T21:43:35') AND TelemetryAssetType = 'test' AND measure_name = 'alarm_status' AND measure_value::varchar {property_filter['operator']} 'abc'  ORDER BY time ASC"""
        else:
            sample_query = """SELECT TelemetryAssetId, measure_name, time, measure_value::double, measure_value::varchar FROM CookieFactoryTelemetry.Telemetry  WHERE time > from_iso8601_timestamp('2021-10-18T21:42:58') AND time <= from_iso8601_timestamp('2021-10-18T21:43:35') AND TelemetryAssetType = 'test' AND measure_name = 'alarm_status'   ORDER BY time ASC"""

        query_string = f"SELECT TelemetryAssetId, measure_name, time, measure_value::double, measure_value::varchar" \
            f" FROM {self.database_name}.{self.table_name} " \
            f" WHERE time > from_iso8601_timestamp('{request.start_datetime.isoformat()}')" \
            f" AND time <= from_iso8601_timestamp('{request.end_datetime.isoformat()}')" \
            f" AND TelemetryAssetType = '{telemetry_asset_type}'" \
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -