from influxdb_client_3.write_client.client.write.dataframe_serializer import DataframeSerializer
from influxdb_client_3 import PointSettings
import pandas as pd

# make an example dataframe with nullable dtypes
df = pd.DataFrame({
    "bool": [True, False, None],
    "int": [1, 2, None],
    "float": [1.0, 2.0, None],
    "str": ["a", "b", None],
})
df['bool'] = df['bool'].astype(pd.BooleanDtype())
df['int'] = df['int'].astype(pd.Int64Dtype())
df['float'] = df['float'].astype(pd.Float64Dtype())
df['str'] = df['str'].astype(pd.StringDtype())

df.index = pd.to_datetime(["2021-01-01", "2021-01-02", "2021-01-03"])

ps = PointSettings()

serializer = DataframeSerializer(df, point_settings=ps, precision="ms",  data_frame_measurement_name="test")

lines = serializer.serialize()