influxdb_issue.py

from influxdb import InfluxDBClient

db = "logs"
client = InfluxDBClient("localhost", 8086, "root", "root", db)

try:
    client.delete_database(db)
except:
    pass

client.create_database(db)
client.add_database_user("root", "root")

nb = 10
for i in xrange(0, nb):
    json_body = [{
        "points": [
            ['FR:VSS:ILD:DC', 0, 200],
            ['CA:BHS:OVH:DC', 0, 200],
            ['FR:SHB:FRE:A9M', 0, 200],
            ['all', 0, 200]
        ],
        "name": "hosta",
        "columns": ["source", "state", "msg"]
    }]

    client.write_points(json_body)

query = "select * from hosta"
result = client.query(query)
points = result[0]['points']

print("\nTest1:")
print(" + Query: '%s'" % query)
print(" + Nb points: %s" % len(points))

query = "select * from hosta where source == 'all'"
result = client.query(query)
points = result[0]['points']

print("\nTest2:")
print(" + Query: '%s'" % query)
print(" + Nb points: %s" % len(points))

query = "select * from hosta where source == 'all' limit 5"
result = client.query(query)
points = result[0]['points']

print("\nTest3:")
print(" + Query: '%s'" % query)
print(" + Nb points: %s" % len(points))