typeError使用Python的AioInflux用户定义的模式，将数据写入涌入时，没有值

Question

因此，我有一个我定义的架构，并与aioinflux库一起使用，以将Python的数据写入infuxdb：

from datetime import datetime
from aioinflux import lineprotocol, TIMEDT, TAG, FLOAT, MEASUREMENT, INT
from dataclasses import dataclass
from typing import Optional


@lineprotocol(
    schema=dict(
        timestamp=TIMEDT,
        measurement=MEASUREMENT,
        object_id=INT,
        dt=TAG,
        weight=FLOAT,
        width=FLOAT,
        size=FLOAT,
        risk=TAG,
        confidence=FLOAT,
    )
)
@dataclass
class CbdrDebugPoint:
    timestamp: datetime
    object_id: int
    dt: str
    weight: float
    size: Optional[float]
    width: Optional[float]
    risk: Optional[str]
    confidence: Optional[float]
    measurement: str = "my_table_name"

但是，如果我的任何一个我的可选>可选字段获取值等于none涌入的写作失败，

TypeError("Invalid variable type: value should be str, int or float, got None")

但可以肯定可以写入null值为涌入，所以任何想法为什么会出现此错误？

Answer 1

因此，在挖掘出 aioinflux package ，似乎是这种情况的行为：

• 如果尝试使用字典中的字典格式编写数据，它确实接受none在字典中，它只是将它们从写入涌入的文字中，以便您获得所需的行为
  - 如果您将使用定义的模式与dataclass使用相同的行为，则它实际上试图将其实际写入inter ，并且失败

了是我的是将用户定义的模式保留为文档的缩短aioinflux的字典期望如下所示：

from datetime import datetime
from aioinflux import lineprotocol, TIMEDT, TAG, FLOAT, MEASUREMENT, INT
from dataclasses import dataclass
from typing import Optional


@lineprotocol(
    schema=dict(
        timestamp=TIMEDT,
        measurement=MEASUREMENT,
        object_id=INT,
        dt=TAG,
        weight=FLOAT,
        width=FLOAT,
        size=FLOAT,
        risk=TAG,
        confidence=FLOAT,
    )
)
@dataclass
class CbdrDebugPoint:
    timestamp: datetime
    object_id: int
    dt: str
    weight: float
    size: Optional[float]
    width: Optional[float]
    risk: Optional[str]
    confidence: Optional[float]
    measurement: str = "my_table_name"

    def to_dict(self):
        return {
            "measurement": "my_table_name",
            "fields": {
                "object_id": self.object_id,
                "weight": self.weight,
                "size": self.size,
                "width": self.width,
                "confidence": self.confidence,
            },
            "tags": {
                "dt": self.dt,
                "risk": self.risk,
            },
            "time": self.timestamp,
        }

然后在写入infux之前，我产生了此词典。这是一个黑客，但是鉴于库不支持用户定义的架构编写 none ，这是一个可接受的解决方案。