欢迎参加北京坤铭体质监测评估中心中医体质检测
\n", "\n", "\"\"\"\n", " from_addr = 'kmingedu@163.com' #发件邮箱\n", " password = 'GKWUZXMVYKSSUSSL' #邮箱密码\n", " smtp_server = 'smtp.163.com' #SMTP服务器，以新浪为例\n", " server = smtplib.SMTP(smtp_server,25) #第二个参数为默认端口为25，有些邮件有特殊端口\n", " msg = MIMEText(mail_msg, 'html', 'utf-8')\n", " msg['Subject'] = Header(\"中医体质检测测试链接\",'utf-8')\n", " msg['From'] = Header('北京坤铭体质监测评估中心')\n", " msg['To'] = Header(m_mail)\n", "\n", " \n", " to_addr = m_mail #收件邮箱\n", " try:\n", " server.login(from_addr,password) #登录邮箱\n", " server.sendmail(from_addr,to_addr,msg.as_string()) #将msg转化成string发出\n", " server.quit\n", " time.sleep(5)\n", " print('邮件发送成功！')\n", " except smtplib.SMTPException:\n", " print (\"Error: 无法发送邮件\")\n", " " ] }, { "cell_type": "code", "execution_count": null, "metadata": {}, "outputs": [], "source": [ "try:\n", " server.login(from_addr,password) #登录邮箱\n", " server.sendmail(from_addr,to_addr,msg.as_string()) #将msg转化成string发出\n", " server.quit\n", " time.sleep(5)\n", " print(f'{fl}邮件发送成功！')\n", " except smtplib.SMTPException:\n", " print (\"Error: 无法发送邮件\")\n", " " ] }, { "cell_type": "markdown", "metadata": { "toc-hr-collapsed": true, "toc-nb-collapsed": true }, "source": [ "# Twilio使用" ] }, { "cell_type": "code", "execution_count": null, "metadata": {}, "outputs": [], "source": [ "import os\n", "from twilio.rest import Client\n", "\n", "\n", "# Your Account Sid and Auth Token from twilio.com/console\n", "# and set the environment variables. See http://twil.io/secure\n", "account_sid = 'AC1aac8c18078bf371992fda0f924860c8'\n", "auth_token = '956199d0f1b724d00ef8bb934fcaefe9'\n", "client = Client(account_sid, auth_token)\n", "\n", "message = client.messages \\\n", " .create(\n", " body=\"I'm back.\",\n", " from_='+12056066931',\n", " to='+8613793180751'\n", " )\n", "\n", "print(message.sid)" ] }, { "cell_type": "code", "execution_count": null, "metadata": {}, "outputs": [], "source": [ "import time\n", "\n", "localtime = time.localtime(time.time())\n", "#type(localtime)\n", "print (\"本地时间为 :\", localtime)\n", "jyr = '12345'\n", "if time.strftime(\"%w\", time.localtime()) in jyr:\n", " print('ok')\n", "else:\n", " print('今日不是交易日！')\n" ] }, { "cell_type": "code", "execution_count": null, "metadata": {}, "outputs": [], "source": [ "from email.mime.text import MIMEText\n", "from email.header import Header\n", "import smtplib\n", "import requests\n", "import time\n", "import re\n", "\n", "def sendmail(message):\n", " msg = MIMEText(message,'plain','utf-8')\n", " msg['Subject'] = Header(\"外汇价格已经到达预期价位！\",'utf-8')\n", " msg['From'] = Header('512song@sina.com')\n", " msg['To'] = Header('songyi@yeah.net','utf-8')\n", "\n", " from_addr = '512song@sina.com' #发件邮箱\n", " password = '409fe5d8471da663' #邮箱密码\n", " to_addr = 'songyi@yeah.net' #收件邮箱\n", " smtp_server = 'smtp.sina.com' #SMTP服务器，以新浪为例\n", " server = smtplib.SMTP(smtp_server,25) #第二个参数为默认端口为25，有些邮件有特殊端口\n", " server.login(from_addr,password) #登录邮箱\n", " server.sendmail(from_addr,to_addr,msg.as_string()) #将msg转化成string发出\n", " server.quit() \n", " \n", " \n", "\n", "pattern = re.compile(r'\\\"(.*)\\\"')\n", "url = 'http://hq.sinajs.cn/list=USDCAD'\n", "strhtml = requests.get(url)\n", "data = strhtml.text\n", "if pattern.findall(data):\n", " for data1 in pattern.findall(data):\n", " data2 = data1.split(',')\n", "#print(data2)\n", "with open('price.txt','r') as fl:\n", " for line in fl:\n", " p_high = line.split(',')[0]\n", " p_low = line.split(',')[1]\n", "m_message = '当前美元加元买入价：{}'.format(data2[1])\n", "while time.strftime(\"%w\", time.localtime()) in '12345':\n", " \n", " print(p_high,p_low)\n", " time.sleep(10)\n", " strhtml = requests.get(url)\n", " data = strhtml.text\n", " if pattern.findall(data):\n", " for data1 in pattern.findall(data):\n", " data2 = data1.split(',')\n", " if float(data2[1]) > float(p_high):\n", " m_message = '当前美元加元买入价：{}'.format(data2[1])\n", " sendmail(m_message)\n", " p_high = str(float(p_high) + 0.04) \n", " if float(data2[1]) > float(p_high):\n", " m_message = '当前美元加元卖出价：{}'.format(data2[2])\n", " p_low = str(float(p_low) - 0.04)\n", " sendmail(m_message)\n", " time.sleep(900)\n", " " ] }, { "cell_type": "markdown", "metadata": { "toc-hr-collapsed": true, "toc-nb-collapsed": true }, "source": [ "# AWS应用" ] }, { "cell_type": "markdown", "metadata": {}, "source": [ "## AWS获取sns信息" ] }, { "cell_type": "code", "execution_count": null, "metadata": {}, "outputs": [], "source": [ "import boto3\n", "\n", "# Create an SNS client\n", "sns = boto3.client('sns')\n", "\n", "# Call SNS to list topics\n", "response = sns.list_topics()\n", "\n", "# Get a list of all topic ARNs from the response\n", "topics = [topic['TopicArn'] for topic in response['Topics']]\n", "\n", "# Print out the topic list\n", "print(\"Topic List: %s\" % topics)" ] }, { "cell_type": "markdown", "metadata": {}, "source": [ "## AWS操作DynamoDB" ] }, { "cell_type": "code", "execution_count": null, "metadata": {}, "outputs": [], "source": [ "import boto3\n", "\n", "# Get the service resource.\n", "dynamodb = boto3.resource('dynamodb')\n", "\n", "# Create the DynamoDB table.\n", "table = dynamodb.create_table(\n", " TableName='waihui',\n", " \n", " AttributeDefinitions=[ \n", " {\n", " 'AttributeName': 'code',\n", " 'AttributeType': 'S'\n", " }\n", " \n", " \n", " ],\n", " KeySchema=[\n", " {\n", " 'AttributeName': 'code',\n", " 'KeyType': 'HASH'\n", " }\n", " \n", " ],\n", " ProvisionedThroughput={\n", " 'ReadCapacityUnits': 5,\n", " 'WriteCapacityUnits': 5\n", " }\n", " \n", ")\n", "\n", "# Wait until the table exists.\n", "table.meta.client.get_waiter('table_exists').wait(TableName='waihui')\n", "\n", "# Print out some data about the table.\n", "print(table.item_count)" ] }, { "cell_type": "code", "execution_count": null, "metadata": {}, "outputs": [], "source": [ "import boto3\n", "import decimal\n", "# Get the service resource.\n", "dynamodb = boto3.resource('dynamodb')\n", "\n", "table = dynamodb.Table('waihui')\n", "\n", "table.put_item(\n", " Item={\n", " 'code': 'USDCAD',\n", " 'high': Decimal('1.3200'),\n", " 'low': Decimal('1.3000'),\n", " }\n", ")" ] }, { "cell_type": "code", "execution_count": null, "metadata": {}, "outputs": [], "source": [ "import boto3\n", "# Get the service resource.\n", "dynamodb = boto3.resource('dynamodb')\n", "\n", "table = dynamodb.Table('waihui')\n", "\n", "response = table.get_item(\n", " Key={\n", " 'code': 'USDCAD' \n", " }\n", ")\n", "item = response['Item']\n", "print(item)" ] }, { "cell_type": "code", "execution_count": null, "metadata": {}, "outputs": [], "source": [ "import boto3\n", "# Get the service resource.\n", "dynamodb = boto3.resource('dynamodb')\n", "\n", "table = dynamodb.Table('waihui')\n", "\n", "table.delete_item(\n", " Key={\n", " 'code': 'USDCAD' \n", " }\n", ")\n" ] }, { "cell_type": "code", "execution_count": null, "metadata": {}, "outputs": [], "source": [ "import boto3\n", "import decimal\n", "# Get the service resource.\n", "dynamodb = boto3.resource('dynamodb')\n", "\n", "table = dynamodb.Table('waihui')\n", "table.update_item(\n", " Key={\n", " 'code': 'USDCAD'\n", " },\n", " UpdateExpression='SET low = :val1',\n", " ExpressionAttributeValues={\n", " ':val1': decimal.Decimal('1.2900')\n", " }\n", ")\n" ] }, { "cell_type": "code", "execution_count": null, "metadata": {}, "outputs": [], "source": [ "import boto3\n", "\n", "# Create SQS client\n", "sqs = boto3.client('sqs')\n", "\n", "queue_url = 'https://sqs.us-east-1.amazonaws.com/915521803346/MySqs1'\n", "\n", "# Receive message from SQS queue\n", "response = sqs.receive_message(\n", " QueueUrl=queue_url,\n", " AttributeNames=[\n", " 'SentTimestamp'\n", " ],\n", " MaxNumberOfMessages=1,\n", " MessageAttributeNames=[\n", " 'All'\n", " ],\n", " VisibilityTimeout=0,\n", " WaitTimeSeconds=0\n", ")\n", "\n", "message = response['Messages'][0]\n", "receipt_handle = message['ReceiptHandle']\n", "\n", "# Delete received message from queue\n", "sqs.delete_message(\n", " QueueUrl=queue_url,\n", " ReceiptHandle=receipt_handle\n", ")\n", "print('Received and deleted message: %s' % message)" ] }, { "cell_type": "markdown", "metadata": {}, "source": [ "# MongoDB系统GridFS文件管理" ] }, { "cell_type": "markdown", "metadata": {}, "source": [ "## 文件上传" ] }, { "cell_type": "code", "execution_count": null, "metadata": { "tags": [] }, "outputs": [], "source": [ "import pymongo\n", "from gridfs import GridFS\n", "from bson.objectid import ObjectId\n", "import os\n", "\n", "myclient = pymongo.MongoClient('mongodb://localhost:27017/')\n", "mydb = myclient[\"gaokao\"]\n", "mycol = mydb[\"college\"]\n", "\n", "UploadCache = \"uploadcache\"\n", "dbURL = \"mongodb://localhost:27017\"\n", "\n", "#上传文件\n", "def upLoadFile(file_coll,file_name,data_link):\n", " client = pymongo.MongoClient('mongodb://localhost:27017/')\n", "\n", " db = client[\"gaokao\"]\n", "\n", " filter_condition = {\"filename\": os.path.basename(file_name), \"url\": data_link}\n", " gridfs_col = GridFS(db, collection=file_coll)\n", " file_ = \"0\"\n", " query = {\"filename\":\"\"}\n", " query[\"filename\"] = file_name\n", "\n", " if gridfs_col.exists(query):\n", " print('已经存在该文件')\n", " else:\n", "\n", " with open(file_name, 'rb') as file_r:\n", " file_data = file_r.read()\n", " file_ = gridfs_col.put(data=file_data, **filter_condition) # 上传到gridfs\n", "\n", " print(file_)\n", "\n", "\n", " return file_ \n", "# 按文件名获取文档\n", "def downLoadFile(self,file_coll,file_name,out_name,ver):\n", " client = pymongo.MongoClient(self.dbURL)\n", "\n", " db = client[\"store\"]\n", "\n", " gridfs_col = GridFS(db, collection=file_coll)\n", "\n", " file_data = gridfs_col.get_version(filename=file_name, version=ver).read()\n", "\n", " with open(out_name, 'wb') as file_w:\n", " file_w.write(file_data)\n", "\n", "# 按文件_Id获取文档 \n", "def downLoadFilebyID(self,file_coll,_id,out_name):\n", " client = pymongo.MongoClient(self.dbURL)\n", "\n", " db = client[\"store\"]\n", "\n", " gridfs_col = GridFS(db, collection=file_coll)\n", "\n", " O_Id = ObjectId(_id)\n", "\n", " gf = gridfs_col.get(file_id=O_Id)\n", " file_data = gf.read()\n", " with open(out_name, 'wb') as file_w:\n", "\n", " file_w.write(file_data) \n", "\n", "\n", " return gf.filename \n", "m_dir = './data/tmp'\n", "fls=os.listdir(m_dir)\n", "n = 0\n", "for fl in fls:\n", " #oldname=fl[n]\n", " name, suffix = os.path.splitext(fl)\n", " #if name in old:\n", " # new_name = fi_path+ os.sep + fi_name[name]+suffix\n", " # old_name = fi_path+ os.sep + fl[n]\n", " # os.rename(old_name,new_name)\n", " #print(os.path.basename(fl))\n", " #print(fl,suffix[1:])\n", " full_path = m_dir+ '/' + fl\n", " upLoadFile(\"document\",full_path,\"\")\n", "#a = MongoGridFS(\"\")\n", "#a.upLoadFile(\"pdf\",\"MongoGridFS.py\",\"\")\n", "#a.downLoadFile(\"pdf\",\"MongoGridFS.py\",\"out2.p\",2)\n", "#ll = a.downLoadFilebyID(\"pdf\",\"5d70a5b283a3c5104cd39346\",\"out3.p\")\n", "#print (ll)" ] }, { "cell_type": "code", "execution_count": null, "metadata": {}, "outputs": [], "source": [ "import pymongo\n", "from gridfs import GridFS\n", "from bson.objectid import ObjectId\n", "import os\n", "\n", "myclient = pymongo.MongoClient('mongodb://localhost:27017/')\n", "mydb = myclient[\"gaokao\"]\n", "mycol = mydb[\"college\"]\n", "\n", "UploadCache = \"uploadcache\"\n", "dbURL = \"mongodb://localhost:27017\"\n", "\n", "#上传文件\n", "def upLoadFile(file_coll,file_name,data_link):\n", " client = pymongo.MongoClient('mongodb://localhost:27017/')\n", "\n", " db = client[\"gaokao\"]\n", "\n", " filter_condition = {\"filename\": file_name, \"url\": data_link}\n", " gridfs_col = GridFS(db, collection=file_coll)\n", " file_ = \"0\"\n", " query = {\"filename\":\"\"}\n", " query[\"filename\"] = file_name\n", "\n", " if gridfs_col.exists(query):\n", " print('已经存在该文件')\n", " else:\n", "\n", " with open(file_name, 'rb') as file_r:\n", " file_data = file_r.read()\n", " file_ = gridfs_col.put(data=file_data, **filter_condition) # 上传到gridfs\n", "\n", " print(file_)\n", "\n", "\n", " return file_ \n", "# 按文件名获取文档\n", "def downLoadFile(self,file_coll,file_name,out_name,ver):\n", " client = pymongo.MongoClient(self.dbURL)\n", "\n", " db = client[\"store\"]\n", "\n", " gridfs_col = GridFS(db, collection=file_coll)\n", "\n", " file_data = gridfs_col.get_version(filename=file_name, version=ver).read()\n", "\n", " with open(out_name, 'wb') as file_w:\n", " file_w.write(file_data)\n", "\n", "# 按文件_Id获取文档 \n", "def downLoadFilebyID(file_coll,_id,out_name):\n", " client = pymongo.MongoClient('mongodb://localhost:27017/')\n", "\n", " db = client[\"gaokao\"]\n", "\n", " gridfs_col = GridFS(db, collection=file_coll)\n", "\n", " O_Id = ObjectId(_id)\n", "\n", " gf = gridfs_col.get(file_id=O_Id)\n", " file_data = gf.read()\n", " with open(out_name, 'wb') as file_w:\n", "\n", " file_w.write(file_data) \n", "\n", "\n", " return gf.filename \n", "ll = downLoadFilebyID(\"pdf\",\"5fbf351b62452a56d7d16603\",\"out3.pdf\")\n", "print (ll)\n", "#a = MongoGridFS(\"\")\n", "#a.upLoadFile(\"pdf\",\"MongoGridFS.py\",\"\")\n", "#a.downLoadFile(\"pdf\",\"MongoGridFS.py\",\"out2.p\",2)\n", "#ll = a.downLoadFilebyID(\"pdf\",\"5d70a5b283a3c5104cd39346\",\"out3.pdf\")\n", "#print (ll)" ] }, { "cell_type": "code", "execution_count": null, "metadata": {}, "outputs": [], "source": [] } ], "metadata": { "kernelspec": { "display_name": "Python 3 (ipykernel)", "language": "python", "name": "python3" }, "language_info": { "codemirror_mode": { "name": "ipython", "version": 3 }, "file_extension": ".py", "mimetype": "text/x-python", "name": "python", "nbconvert_exporter": "python", "pygments_lexer": "ipython3", "version": "3.12.3" } }, "nbformat": 4, "nbformat_minor": 4 }