rocketreachapi的Python绑定
rocketreach的Python项目详细描述
入门
这是rocketreachapi(https://rocketreach.co/api)的简单Python绑定。在
要求
Python 3.4+版本。在
安装
您可以使用pip安装此软件包:
$ pip install rocketreach
测试
包含一个简单的驱动程序文件main.py
,该文件接受3个必需的参数:
-i <input csv>
-o <output csv>
-k <api key>
输入csv是一个2列csv,名称(第1列)和“公司”(第2列)。 该脚本加载csv并对每一行执行查找,并将结果写入 输出csv。在
注意,如果输出文件存在,这将覆盖它
注意这可能会向与API密钥相关联的帐户收取任何查找费用。
示例csv包含在sample目录中。你可以跑过去
^{pr2}$设置
在https://rocketreach.co/signup注册RocketReach。在
API和python绑定的文档可在官方API文档页:https://rocketreach.co/api。在
使用
配置
提供您的api密钥和环境以开始。在默认环境中,生产环境通常足以启动。
如果要使用测试密钥,请将API key参数留空或None
,并将环境设置为Sandbox。在
import rocketreach
config = rocketreach.GatewayConfig(None, rocketreach.GatewayEnvironment.sandbox)
rr = rocketreach.Gateway(config)
result = rr.account.get()
if result.is_success:
print(result.account)
或者使用简写参数并使用默认的GatewayConfig
:
import rocketreach
rr = rocketreach.Gateway(api_key='my-api-key')
搜索
配置网关后,执行RocketReach搜索:
import rocketreach
rr = rocketreach.Gateway(rocketreach.GatewayConfig('api-key'))
s = rr.person.search().filter(current_employer='Acme', current_title='CEO')
result = s.execute()
for person in result.people:
print(person)
要对搜索查询分页,请调用params()
方法并提供start
和/或{
import rocketreach
rr = rocketreach.Gateway(rocketreach.GatewayConfig('api-key'))
s = rr.person.search().filter(current_employer='Acme', current_title='CEO')
s = s.params(start=11, size=25)
result = s.execute()
for person in result.people:
print(person)
查找
要查找某人,请提供id
或linkedin_url
。请注意,并非所有人都会有id
,因此请确保
允许灵活使用任一属性。至少有一个是肯定存在的。在成功查找之后,
一个人需要有一个id
,它可以用来通过checkStatus()
方法检查查找进度。在
默认情况下,lookup
方法是阻止的,并将此人添加到您的帐户查找中
直到查找完成。在
import rocketreach
rr = rocketreach.Gateway(rocketreach.GatewayConfig('api-key'))
result = rr.person.lookup(person_id=123)
print(result.person)
result = rr.person.lookup(linkedin_url='https://www.linkedin.com/in/john-doe-example')
print(result.person)
检查状态
{{17}如果你不想用cd16}方法,那就用它。
请注意,RocketReach不会阻止lookup API端点,而是系统会将查找标记为
已添加到您的帐户,并将开始在后台搜索联系人信息。系统可能
在某些情况下,完成内联查找,但在大多数情况下,person状态将是不完整的。
使用checkStatus
是找到此人联系信息的最简单方法。在
当调用checkStatus
时,请记住最好避免紧循环,这可能会导致速率限制
错误,由429状态代码指示。如果请求失败,状态代码为,则可以检查错误
消息查看等待下一个请求的时间--通常只有几秒钟。在
import rocketreach
rr = rocketreach.Gateway(rocketreach.GatewayConfig('api-key'))
result = rr.person.lookup(person_id=123, block=False)
while result.status != PersonLookupStatus.complete:
result = rr.person.check_status([result.person.id])
if not result.is_success and result.response.status_code == 429:
time.sleep(1)
- 项目
标签: