实时股票和密码价格的intrinio python sdk

intriniorealtime的Python项目详细描述


#intrinio python sdk用于实时股票、外汇和加密价格

[intrinio](https://intrinio.com/)通过双向websocket连接提供实时股票、外汇和加密价格。要开始使用,[订阅实时数据源](https://intrinio.com/marketplace/data/prices/real time)并按照以下说明操作。

IBE要从单个证券、外汇对或密码进行更新,请订阅所有证券、外汇对或密码的更新(请与我们联系以获取特殊访问)

iorealtime.client导入intriiorealtimeclient

def on戥quote(quote,backlog):
打印("quote:",quote,"backlog length:",backlog)


选项={
"api戥key":"your戥intrinio戥api戥key",
"provider":"iex",
"on戥quote":on戥quote
}

client=intriniorealtimeclient(options)
client.join(['aapl','ge','msft'])
client.connect()
client.keep廑alive()
````

此队列的默认最大大小为10000个引号。如果环境内存限制允许,可以通过指定"最大队列大小"选项修改此值。一旦将报价放入队列中,它将按接收顺序传递给"on_quote"处理程序。您的"on-quote"处理程序应快速处理引号,以便队列不会达到其最大大小(此时,系统将记录错误并忽略任何传入的引号,直到队列有空间为止)。我们建议使用线程类或池进行操作,例如向数据库中写入引号(或任何其他涉及耗时I/O的操作)。"on-quote"处理程序还接收一个"backlog"参数,该参数是一个整数,指定报价队列的大致长度。对此进行监控,确保您处理报价的速度足够快。

注-[主页](https://www.cryptoquote.io/)
*fxcm-[主页](https://www.fxcm.com/)


每个都有不同的价格通道和报价格式,但它们的API非常相似。




注意:来自Quood的消息反映了市场数据的变化。并非所有字段都会出现在每个邮件中。订阅频道后,您将收到一条报价和一条交易消息,其中包含最新可用数据的所有字段。


"成交量":100,
‘成交量’成交量:100,
‘成交量’成交量:100,
‘成交量’成交量:24950,
‘成交量:15892,
‘成交量:24950,
‘成交量:15892,
‘成交量:24950,
‘成交量:15888482,
‘成交量:10209883,
‘成交量:100,
‘成交量’:10209883,
‘成交量:100,
‘成交量:1596600,
‘成交量:24950,
‘成交量:24950,
‘成交量’,
‘U时间:1508164532269,
'day'u low'u 4d':157500,
'day'u low'u时间:1508160605345,
'prev'u close'u 4d':156900,
'volume'u加价':6333150,
'prev'prev'u close'u 4d':156900,
'volume'u加价':6333150,
'extu lasu价格:1579000,
'extxt'u贸易量:100,
'extu贸易量:t,
'extu贸易量:t,
'extu价格:9100,
'extu价格:9100,
'ext,
'ext'ext'变化百分比:5796,
"外部交易时间":1508160600567,
"外部上涨下跌":"—",
"开放价格":1582200,
"开放量":100,
"开放时间":1508141103583,
"RTL":30660,
"暂停":false,
"是短限制"受限:false}
````

**ticker**-证券的股票符号
**root-ticker**-特定合约的基础符号
**last-price-4d**-证券最近交易的价格
**trade-volume**-在上次交易
**trade_exchange**-上次交易发生的市场中心
**trade_time**-证券最后一次交易的时间(毫秒)
**up_down**-勾选指示器-向上或向下-指示上次交易是否比上次交易上升或下降
**change_u price_d**-证券当日收盘价与前一日收盘价之差。
**percent_u change_d**-证券自前一日交易以来上涨或下跌的百分比成交量**纳斯达克成交量加上其他市场中心的成交量,以更准确地匹配综合成交量。用于纳斯达克基本指数
**vwap_4d**-成交量加权平均价格。VWAP的计算方法是将每笔交易的交易金额(价格乘以交易的股票数量)相加,然后除以当天交易的股票总数。
**day_u high_d**-证券的日内最高交易价格。
**day_u high_t**-证券到达的时间d新高
**day_u 4d**-证券的日内低交易价格。
**day d**-证券达到新低的时间
**ext d**-延长时间最后价格(上市前或上市后)
**ext_u交易量**-单次延长交易的股票数量小时交易
***外部交易**-上次交易发生的延长时间交易(上市前或上市后)
***外部交易**-延长时间交易的时间(毫秒)
***外部交易上升下降**-延长时间刻度指示器-上升或下降D小时变动价格(上市前或上市后)
**ext_u percent_u 4d**-延长时间百分比变动(上市前或上市后)
**is_u hald**-表示股票已停止且当前未交易的标志
**is_u short_u restricted**-表示股票当前处于卖空状态的标志受限-意味着您不能卖空真实的股票
**open_u price_u**-证券在给定交易日开市时的首次交易价格
**open_u time**-证券在毫秒内开市的时间
**open_u volume**-数字在开盘交易中交易的股票数量
**prev_close_4d**-证券在交易前一天的收盘价
**protocol_id**-定义数据来源的内部数量ID
**rtl**-记录交易级别-当天公布的记录数

####引述消息


``python
{'ticker''aapl.nb',
'root'ticker''aapl',
'bid'bid'bu出价:500,
'ask'ask'a出价:600,
'bid'bid'bid'bu出价:1594800,
'ask'bu出价:1594900,
'ask'ask'bu出价:1594900,
'ask'ask'bu出价:1594900,
'ask'ask'bu出价:1594900,
'ask'ask'ask'ask'bu出价:出价:1594900,
'ask'as65070850,
保护ocol_id:302,
"rtl":129739}
````

**ticker**-证券的股票符号
**root_ticker**-特定合同的基础符号
**ask_price_4d**-卖方愿意接受的证券价格做市商提出以卖出价出售,卖出价为买入价的市场中心。以指定的投标价格
**bid_exchange**-报价的市场中心
**quote_time**-报价时间(毫秒)
**rtl**-记录交易n level-当天发布的记录数
***protocol-protocol-id-id-id-id-id-id-id-id-id-id-id-id-id-id-id-id-id-id-id-id-id-id-id-id-id-id-id-id-id定义数据源

<<
`` python
{‘type’:‘ask’,
‘timestamp’:1493409509.3932788,
‘ticker’:‘ge’,
‘size’:13750,
‘price’:13750,
‘price’:28.97}:28.97}
``T型type**-报价类型
**`last`**-表示最后交易价格
**`bid`**-表示图书出价最高价格
**`ask`**-表示图书出价最高价格
**timestamp**-Unix时间戳(精度微秒)
**ticker**-勾号安全性的ER
**size**-图书顶部的"最后一笔"交易或订单总量"出价"或"要价"的大小
**price**-美元价格

价值观。


``python
{'last'u updated':'2018-10-29 23:08:08:02.277z',
'pa对名''btcusd',
'pa对码''btcusd',
'pa对名''btcusd',
'pa对名''btcusd',
'exchang名''binance',
'exchang名''binance',
'exchang代码''binance',
'bid''bid''bid''binance',
'bid''bid''bid':6326,
'bid':6326,
'bid'br/>"询问尺寸":6.12643000,
'变化':-151.689999999999999999999999996,
'变化百分比':-2.34008950617288389,
'成交量':13777.232772,
'开盘':6480,
'高':6505.01,
'低':6315,
'上一次贸易时间':'2018-10-29 23:08:01.834Z',
'低':6315,
'上一次贸易时间':'2018-10-29-10-29 23:08:01.834Z',
'上一次贸易区',
'上一次贸易区':无,
'上一次价格:6326.97000000,
"上次交易大小":0.00001200,
"类型":"级别1"}
````

**"上次更新时间**-上次更新数据的UTC时间戳
**"对名称**-货币对名称
**"对代码**-货币对代码
**"交换名称**-t"交易所名称_ size**-交易所货币对的出价大小
**change**-自上一个报价人以来的名义价格变化
**change_percent**-自上一个报价人以来的价格变化百分比
**volume**-交易所货币对的交易量
**open**-交易所货币对的开盘价
**high**-交易所货币对的最高价格
**low**-交易所货币对的最低价格
**last懔trade懔time**-T上货币对最后一次交易的UTC时间戳他交换了最后一笔交易的价格change
**last廑trade廑size**-交易所货币对的最后一笔交易的大小
**type**-此消息的类型为
**`level廑1`**-表示更改最后交易价格或出价或要价的消息这意味着订单簿的变更



\\\\\\\\\


大小:0.3,
"类型":"bo确定更新'}
````

**pair-name**-货币对的名称
**pair-code**-货币对的代码
**exchange-name**-兑换的名称
**exchange-code**-兑换的代码
**side**-本次更新的目的地
**`buy`**-这是对书的buy端的更新
**`sell`**-这是对图书的卖方
**price**-此图书分录的价格
**size**-此图书分录的大小
**type**-此消息的类型为
**level\u 1`**-表示最后交易价格或图书出价或要价变动的消息一条表示订单变更的消息





<
<
<
<
<<
z"}
```

***代码**-外汇货币代码ncy pair
***出价**-出价是买方愿意支付的价格
***出价**-出价是卖方愿意接受的价格
***时间**-价格更新的UTC时间戳

Om Quodd,你需要指示客户"加入"一个频道。频道可以是
*带有数据源名称(`aapl.nb`,`msft.nb`,`ge.nb`,等等)的安全标签


iex

要从iex接收报价,您需要指示客户"加入"频道。一个频道可以是
*一个证券票务(`aapl`,`msft`,`ge`,等等)
*一个证券大厅(`$lobby`),所有证券的所有报价都张贴在那里
*一个证券最后价格大厅(`$lobby`,最后价格大厅),所有证券的最后价格都张贴在那里

两个大厅通道都需要。[联系我们](mailto:sales@intrinio.com)了解更多信息。


一个通道可以是

*`crypto:market\u level\u 1:{pair\u code}`-一级市场通道,其中所有交易所中提供的货币对的所有一级价格更新都将发布(即'crypto:market\u level\u 1:btcusd`)
*`crypto:exchange\u level\u 1:{exchange\u code}:{pair\u code}`-一级市场通道提供的货币对和兑换的所有一级价格更新发布的KET通道
*`crypto:exchange@level@exchange@code}:{pair@code}`-提供的货币对和兑换的所有二级图书更新发布的二级市场通道
*`crypto:firehose`-发布所有货币对的所有消息类型的firehose通道(需要特殊访问)

intrinio rest api提供了对、交换及其相应代码的列表:

*[加密货币对](https://docs.intrinio.com/documentation/download/crypto currency pairs_pairs)
*[加密交换](https://docs.intrinio.com/documentation/download/crypto-exchanges)


通道可以是

*`fxcm:pair:{pair_code}`-发布所提供货币对价格更新的外汇货币对通道(即'fxcm:pair:eur/usd`)
*`fxcm:base:{currency_code}`-更新所提供外汇货币对价格的外汇货币通道作为基础货币的货币(即'fxcm:base:eur'将公布欧元/美元、欧元/日元等的价格)
*`fxcm:quote:{currency_code}`-外汇货币频道,在该频道中,任何以提供的货币作为报价货币的外汇货币对的价格都将更新(即'fxcm:quote:eur'将公布价格s来自欧元/美元、日元/美元等)


intrinio rest api提供了一个对、货币及其相应代码的列表:

*[fx货币](https://docs.intrinio.com/documentation/download/currences)
*[fx货币对](https://docs.intrinio.com/documentation/download/currency_pairs)

\api密钥
[创建帐户](https://intrinio.com/signup)后,您将收到intrinio api密钥。您还需要订阅[实时数据源](https://intrinio.com/marketplace/data/prices/realtime)。


方法

`client=intriniorealtimeclient(options)`-创建intrinio实时客户端
**parameter**`options.api_key`:intrinio api key
**parameter**`options.provider`:要使用的实时数据提供程序("iex","quodd","cryptoquote")
**parameter**`options.on_quote(quote,backlog)`:(可选)处理接收到的引号的函数。` backlog`是一个整数,表示未处理引号队列的大致大小
**parameter**`options.channels`:(可选)连接后要连接的通道数组
**parameter**`options.logger`:(可选)用于记录python的python logger实例
在报价(报价,积压)上定义:
打印("报价:",报价,"积压长度:",积压)


选项={
"API密钥":"您的Intrinio API密钥",
"提供程序":"IEX",
"在报价上":在报价上----

`client.connect()`-检索身份验证令牌,打开WebSocket连接,启动自愈和心跳间隔,连接请求的通道。

----

`client.keep_alive()`-运行无限循环以保持线程活动,以便客户端继续接受价格。您可以在"connect()"之后调用此函数,或使用自己的计时逻辑(例如:connect、侦听x分钟的引号、disconnect)。

--


`client.disconnect()`-关闭WebSocket,停止自愈和心跳间隔。您必须调用此函数来处理客户端。

--


`client.on-quote(quote,backlog)`-更改quote handler函数
``python
`def on-quote(quote,backlog):
print("quote:",quote,"backlog length:",backlog)


client.on-quote=on-quote
```

----

`client.join(channels)`-连接给定的通道。这可以随时调用。客户端将自动注册加入的通道并使用WebSocket连接建立正确的订阅。
**parameter**"channels"--单个通道或通道列表
``python
client.join(["aapl","msft","ge"])
client.join("goog")
```

---

`client.leave(channels)`-离开给定的频道。
**

欢迎加入QQ群-->: 979659372 Python中文网_新手群

推荐PyPI第三方库


热门话题
如何使用Netbeans在Java中创建可执行文件   swing Set不透明(真/假);JAVA   java JPA无法删除具有onotomany关系和cascatype all的实体   java Hibernate自参考映射难题   Java/从字符串到Java代码   java为什么我已经在取整了,却得到了一个无终止小数扩展?   java Wicket onsubmit信息对话框   java如何使用类、类加载器和URL获取资源   java在多模块项目中使用License Maven插件时出错   java HashSet“contains”方法是如何工作的?   图像JavaPNG显示为黑色   java如何在保持内容完整的同时在两个活动之间切换?   JAVA在Tomcat 7.0.27中,WAR无法为Prod正确解包   listview的java onclicklistener   JavaXPages托管Bean可以跨多个数据库工作吗?   java无法停止服务空对象引用错误Android   java将UTF8编码的字符串转换为人类可读的字符串   JavaSpring与JBossSAML的集成   java如何替换AuthorizationCodeInstalledApp类?