PROSAGA码农传奇-InfluxDB-在使用替换字段值查询后，将系列转储回InfluxDB

<div class =“post-text”itemprop =“text”>
  <P>
    该
     <code>
      batch_size
    </code>
     实际上是需要传递给的测量列表的长度
     <code>
      write_points
    </code>
    。
  </p>
  <H2>
    脚步
  </H2>
  <OL>
    <LI>
      <P>
        从测量创建客户端和查询（这里，我们查询gps信息）
      </p>
       <pre>
        <code>
          client = InfluxDBClient(database='dummy')

op = client.query('SELECT * FROM gps WHERE "status"=0', epoch='ns')

</code>
      </pre>
    </LI>
    <LI>
      <P>
        制作
         <code>
          ResultSet
        </code>
         列表：
      </p>
       <pre>
        <code>
           batch = list(op.get_points('gps'))

</code>
      </pre>
    </LI>
    <LI>
      <P>
        创建一个空列表进行更新
      </p>
       <pre>
        <code>
           updated_batch = []

</code>
      </pre>
    </LI>
    <LI>
      <P>
        解析每个测量并更改
         <code>
          status
        </code>
         国旗到
         <code>
          1
        </code>
        。注意，InfluxDB中的默认值是float
      </p>
       <pre>
        <code>
             for each in batch:
new_mes = {
'measurement': 'gps',
'tags': {
'type': 'gps'
},
'time': each['time'],
'fields': {
  'lat': float(each['lat']),
  'lon': float(each['lon']),
  'alt': float(each['alt']),
  'status': float(1)
}
}
updated_batch.append(new_mes)

</code>
      </pre>
    </LI>
    <LI>
      <P>
        最后通过客户端将积分转回
         <code>
          batch_size
        </code>
         作为长度
         <code>
          updated_batch
        </code>
      </p>
       <pre>
        <code>
          client.write_points(updated_batch, batch_size=len(updated_batch))

</code>
      </pre>
    </LI>
  </醇>
  <P>
    这会覆盖系列，因为它包含相同的时间戳
     <code>
      status
    </code>
     字段设置为
     <code>
      1
    </code>
  </p>
</DIV>