4

因此，我尝试遵循将 MySQL 结果集转换为 NumPy 数组的最有效方法是什么？但我仍然有问题。

我的数据库行是 57 个无符号整数（Unix 纪元加上 28 个交换机端口中每一个的字节数，进出）。

我的代码如下所示：

import MySQLdb as mdb
import numpy

# get the database connector
DBconn = mdb.connect('localhost', 'root', '<Password>', 'Monitoring')

with DBconn:

    # prepare a cursor object using cursor() method
    cursor = DBconn.cursor()

    # now get the data for the last 10 minutes
    sql = "select * from LowerSwitchBytes where ComputerTime >= (unix_timestamp(now())-(60*10))"
    cursor.execute(sql)

    results = cursor.fetchall()
    for row in results:
        print row

这样会打印出 10 行，例如：

(1378151928L, 615983307L, 517980853L, 25355784L, 117110102L, 0L, 0L, 0L, 0L, 0L, 0L, 0L, 0L, 0L, 0L, 0L, 0L, 0L, 0L, 0L, 0L, 0L, 0L, 0L, 0L, 267680651L, 288368872L, 84761960L, 337403085L, 224270992L, 335381466L, 27238950843L, 549910918625L, 240002569249L, 11167210734L, 0L, 0L, 0L, 0L, 0L, 0L, 0L, 0L, 222575491L, 335850213L, 223669465L, 339800088L, 310004136202L, 16635727254L, 0L, 0L, 16590672L, 147102083L, 0L, 0L, 0L, 0L)

但是当我改变：

    results = cursor.fetchall()
    for row in results:
        print row

至

    A = numpy.fromiter(cursor.fetchall(), count=-1, dtype=numpy.uint32)
    print A

我得到：

Traceback (most recent call last):
  File "min.py", line 23, in <module>
    A = numpy.fromiter(cursor.fetchall(), count=-1, dtype=numpy.uint32)
ValueError: setting an array element with a sequence.

知道我做错了什么吗？

4

1 回答 1

2

np.fromiter正在抱怨，因为它试图将一整行输入写入新数组的单个项目中。您可以使用记录数组解决此问题：

A = numpy.fromiter(cursor.fetchall(), count=-1,
                   dtype=[('', numpy.uint8)]*57)

如果您的所有记录都属于同一类型，那么您可以得到一个数组视图，如下所示：

A = A.view(numpy.uint8).reshape(-1, 57)
于 2013-09-02T21:01:06.450 回答