用Python调用短信API,实现价格提醒

in #btc7 years ago (edited)

混迹币圈已大半个月,觉币价波动剧烈,BTC上探17000后,急速降至13000~14000内震荡,看ETH已经翻倍,着实眼馋,不知BTC何时才能起飞。无奈大部分资金被套,只有少量资金可用于短线操作,每天买卖挣得一、两美元,实乃极大鼓舞,令新韭菜我欢心不已。可为这点小利,搭上大量时间,又觉不值,遂有一念,若有自动价格提醒功能应是极好的。

想起万能的阿里云,在众多功能中,有“短信服务”,通知迅速,价格......还行,正是想要的。

每天10条,不到5毛,还可以接受。

使用的前提:

有实名认识的阿里云账号,并充入少量资金,没有最低的余额要求。这是我的余额,可以正常发短信。

使用准备:

“签名” 和 “模板”是需要人工审核的,审核的时间还算比较快,周一至周日都可审核,最长2小时。“签名”就是短信的署名,我是用实名申请的,很快通过了。但申请模板时,申请了三次才通过。模板就是短信的内容,其中可加入一些变量。开始想着就是给自己看的,就只加了一个币名的变量,其它内容很简单。这样没过,后来把我的网站域名加上,再把短信内容写得详细了一些,让审核的人能看出明确的用途后才通过。

AK是使用短信服务的密钥,获取后仅可下载一次。包含AccessKeyId与AccessKeySecret,之后加入程序中。

实现自动发送短信功能:

这里有较详细的API使用说明。但阿里的文档太简单,而且不完善,有几点注意的问题,给大家提个醒:

  • 在下载API,Python的API地址,解压打开后,有四个文件夹:api_demo、api_sdk、msg_demo、msg_sdk。如果只用来发送短信和查看发送状态,只用api_demo与api_sdk就可以了。

  • 进入api_sdk->aliyun-python-sdk-dysmsapi路径,执行python setup.py,会自动建立工作环境。

  • 将api_demo->alicom-python-sdk-dysmsapi中的demo.py拷贝到api_sdk->aliyun-python-sdk-dysmsapi中。

  • 将api_sdk->aliyun-python-sdk-core中的aliyunsdkcore文件夹拷贝到api_sdk->aliyun-python-sdk-dysmsapi中。

  • 之后是这样的文件结构:

  • 修改demo.py中的 ACCESS_KEY_ID、ACCESS_KEY_SECRET为自己的,将name = 'query’改为:name = 'send',用来发送短信。

  • print send_sms(__business_id, “手机号”, “申请的签名”, “申请的模板编号,如SMS_121851111", params),其中params用来给模板中的变量赋值,若变量名为symbol,内容为BTCUSDT,对应的params:

params = "{\"symbol\":\"BTCUSDT\"}"

至此,直接运行demo.py,手机上就能收到短信啦。

当然这只实现了发送的功能,若要能自动提醒币价,还需要其它软件的配合,比如github中的ccxt,可查询多个币市的价格。具体如何实现,后面再详细说吧。

最后,附上demo.py的完整代码:

# -*- coding: utf-8 -*-
import sys
from aliyunsdkdysmsapi.request.v20170525 import SendSmsRequest
from aliyunsdkdysmsapi.request.v20170525 import QuerySendDetailsRequest
from aliyunsdkcore.client import AcsClient
import uuid
from aliyunsdkcore.profile import region_provider

"""
短信业务调用接口示例,版本号:v20170525

Created on 2017-06-12

"""

reload(sys)
sys.setdefaultencoding('utf8')

# 注意:不要更改
REGION = "cn-hangzhou"
PRODUCT_NAME = "Dysmsapi"
DOMAIN = "dysmsapi.aliyuncs.com"

# ACCESS_KEY_ID/ACCESS_KEY_SECRET 根据实际申请的账号信息进行替换
ACCESS_KEY_ID = "write your own"
ACCESS_KEY_SECRET = "write your own"

acs_client = AcsClient(ACCESS_KEY_ID, ACCESS_KEY_SECRET, REGION)
region_provider.add_endpoint(PRODUCT_NAME,REGION,DOMAIN)

def send_sms(business_id, phone_numbers, sign_name, template_code, template_param=None):
    smsRequest = SendSmsRequest.SendSmsRequest()
    # 申请的短信模板编码,必填
    smsRequest.set_TemplateCode(template_code)

    # 短信模板变量参数
    if template_param is not None:
        smsRequest.set_TemplateParam(template_param)

    # 设置业务请求流水号,必填。
    smsRequest.set_OutId(business_id)

    # 短信签名
    smsRequest.set_SignName(sign_name);

    # 短信发送的号码列表,必填。
    smsRequest.set_PhoneNumbers(phone_numbers)

    # 调用短信发送接口,返回json
    smsResponse = acs_client.do_action_with_exception(smsRequest)

    # TODO 业务处理

    return smsResponse


def query_send_detail(biz_id, phone_number, page_size, current_page, send_date):
    queryRequest = QuerySendDetailsRequest.QuerySendDetailsRequest()
    # 查询的手机号码
    queryRequest.set_PhoneNumber(phone_number)
    # 可选 - 流水号
    queryRequest.set_BizId(biz_id)
    # 必填 - 发送日期 支持30天内记录查询,格式yyyyMMdd
    queryRequest.set_SendDate(send_date)
    # 必填-当前页码从1开始计数
    queryRequest.set_CurrentPage(current_page)
    # 必填-页大小
    queryRequest.set_PageSize(page_size)

    # 调用短信记录查询接口,返回json
    queryResponse = acs_client.do_action_with_exception(queryRequest)

    # TODO 业务处理

    return queryResponse


__name__ = 'send'
if __name__ == 'send':
    __business_id = uuid.uuid1()
    print __business_id
    params = "{\"symbol\":\"BTCUSDT\"}"
    print send_sms(__business_id, "13000000000", "yourownsign", "SMS_121851111", params)

if __name__ == 'query':
    print query_send_detail("1234567^8901234", "13000000000", 10, 1, "20170612")