_time is None when setting timezone through DateHelper

[AaronCarton]

Steps to reproduce:

1. set timezone as seen in:
   feat: add possibility to specify default timezone for datetimes without tzinfo #238
2. query something similar as below
3. returned tables have None as start/stop/time fields

date_utils.date_helper = DateHelper(timezone=tzlocal())
with InfluxDBClient(url=URL, token=TOKEN, org=ORG, timeout=25_000) as client:
   query= f'''import "date"
                   from(bucket: "{BUCKET}")
                      |> range(start: date.truncate(t: now(), unit: 1d), stop: now())
                      |> filter(fn: (r) => r._measurement == "Duiktank")
                      |> aggregateWindow(every: 1h, fn: sum)
                '''
   tables = client.query_api().query(query, org=ORG)

Expected behavior:
Query returns localized time/start/stop

Actual behavior:
Query returns None time/start/stop

Specifications:

• Client Version: 1.29.1
• InfluxDB Version:
• Platform: Windows

[AaronCarton]

Also worth noting that trying to use Flux's timezone function doesn't seem to work with this client either, as it throws an error stating invalid import path timezone

[bednar]

Hi @AaronCarton,

thanks for using our client.

Steps to reproduce:

1. set timezone as seen in:
   feat: add possibility to specify default timezone for datetimes without tzinfo #238
2. query something similar as below
3. returned tables have None as start/stop/time fields

date_utils.date_helper = DateHelper(timezone=tzlocal())
with InfluxDBClient(url=URL, token=TOKEN, org=ORG, timeout=25_000) as client:
   query= f'''import "date"
                   from(bucket: "{BUCKET}")
                      |> range(start: date.truncate(t: now(), unit: 1d), stop: now())
                      |> filter(fn: (r) => r._measurement == "Duiktank")
                      |> aggregateWindow(every: 1h, fn: sum)
                '''
   tables = client.query_api().query(query, org=ORG)

Expected behavior: Query returns localized time/start/stop

Actual behavior: Query returns None time/start/stop

Specifications:

• Client Version: 1.29.1
• InfluxDB Version:
• Platform: Windows

The #238 is supposed only for writes... I will update the DateHelper docs to clarify how to deal with your requirements. Meanwhile you can use following piece of code:

from influxdb_client.client.util import date_utils
from influxdb_client.client.util.date_utils import DateHelper
import dateutil.parser
from dateutil import tz

def parse_date(date_string: str):
    return dateutil.parser.parse(date_string).astimezone(tzlocal())

date_utils.date_helper = DateHelper()
date_utils.date_helper.parse_date = parse_date

Also worth noting that trying to use Flux's timezone function doesn't seem to work with this client either, as it throws an error stating invalid import path timezone

How looks your query? The following code works for me:

p = {"_start": datetime.timedelta(hours=-1),
     "_location": "Prague",
     "_desc": True,
     "_floatParam": 25.1,
     "_every": datetime.timedelta(minutes=5)
     }

tables = query_api.query('''
    import "timezone"

    timezone.location(name: "America/Los_Angeles")
    
    from(bucket:"my-bucket") |> range(start: _start)
        |> filter(fn: (r) => r["_measurement"] == "my_measurement")
        |> filter(fn: (r) => r["_field"] == "temperature")
        |> filter(fn: (r) => r["location"] == _location and r["_value"] > _floatParam)
        |> aggregateWindow(every: _every, fn: mean, createEmpty: true)        
        |> sort(columns: ["_time"], desc: _desc) 
''', params=p)

Regards

[AaronCarton]

Thanks, this fixes part of the problem!

Although when I query data with start: date.truncate(t: now(), unit: 1d) it will still return data starting from 2 am instead of midnight (my timezone is 2 hours ahead of UTC)

I suspect this is because the now() I'm the Flux query still returns UTC instead of localized time? Which might be what https://docs.influxdata.com/flux/v0.x/stdlib/timezone/location/ would fix?

[AaronCarton]

It seems that import "timezone" is only available on InfluxDB 2.1, and the server I'm querying is still running on 2.0.8, I'll close this issue then 👍