0

我在将工作脚本从 SQLite 迁移到 PGSQL 时遇到困难。我正在使用 SQLalchemy。当我运行脚本时,它会引发以下错误:

raise exc.DBAPIError.instance(statement, parameters, e, connection_invalidated=is_disconnect)

sqlalchemy.exc.ProgrammingError: (ProgrammingError) can't adapt 'INSERT INTO cnn_hot_stocks (datetime, list, ticker, price, change, "pctChange") VALUES (%(datetime)s, %(list)s, %(ticker)s, %(price)s, %(change)s, %(pctChange)s)' {'price': Decimal('7.94'), 'list': 'active', 'datetime': datetime.datetime(2012, 6, 23, 11, 45, 1, 544361), 'pctChange': u'+1.53%', 'ticker': u'BAC', 'change': Decimal('0.12')}

使用 sqlite 引擎时插入调用效果很好,但我想使用 pgsql 来利用本机 Decimal 类型来保持财务数据正确。我复制了脚本,只是将数据库引擎更改为我的 postgresql 服务器。对于这个 SQLalchemy 新手来说,任何关于如何解决这个错误的建议都将不胜感激......我想我对这个问题很感兴趣!提前致谢!

以下是我的相关代码段和表格说明:

dbstring = "postgresql://postgres:postgres@localhost:5432/algo"
db = create_engine(dbstring)
db.echo = True  # Try changing this to True and see what happens
metadata = MetaData(db)

cnn_hot_stocks = Table('cnn_hot_stocks', metadata, autoload=True)

i = cnn_hot_stocks.insert() # running log from cnn hot stocks web-site

def scrape_data():
    try:
            html = urllib2.urlopen('http://money.cnn.com/data/hotstocks/').read()
            markup, errors = tidy_document(html)
            soup = BeautifulSoup(markup,)
    except Exception as e:
            pass
    list_map = { 2 : 'active',
                 3 : 'gainer',
                 4 : 'loser'
               }
    # Iterate over 3 tables on CNN hot stock web-site
    for x in range(2, 5):
            table = soup('table')[x]
            for row in table.findAll('tr')[1:]:
                    timestamp = datetime.now()
                    col = row.findAll('td')
                    ticker = col[0].a.string
                    price = Decimal(col[1].span.string)
                    change = Decimal(col[2].span.span.string)
                    pctChange = col[3].span.span.string
                    log_data = {'datetime'  : timestamp,
                                'list'      : list_map[x],
                                'ticker'    : ticker,
                                'price'     : price,
                                'change'    : change,
                                'pctChange' : pctChange
                               }
                    print log_data
                    # Commit to DB
                    i.execute(log_data)

桌子:

cnn_hot_stocks = Table('cnn_hot_stocks', metadata, # log of stocks data on cnn hot stocks lists
            Column('datetime', DateTime, primary_key=True),
            Column('list', String), # loser/gainer/active
            Column('ticker', String),
            Column('price', Numeric),
            Column('change', Numeric),
            Column('pctChange', String),
            )
4

1 回答 1

0

我对文档的阅读是您必须使用numeric而不是decimal.

PostgreSQL 没有命名类型decimal(它是数字的别名,但不是一个功能非常全面的类型),并且 SQL Alchemy 似乎期望numeric它可以用作抽象目的的类型。

于 2013-04-03T03:54:03.097 回答