#!/usr/bin/python3    
# encoding: utf-8    
import pandas as pd    
import rqdatac    
import rqfactor    
from rqfactor.execute.engine_data_source import FactorEngineDataSource    
from rqfactor.engine import FactorExecutionEngine    
    
rqdatac.init()  # 需要账号密码 请参照 rqdata 文档    
data_source_path = r'D:\data\rqpro\bundle'  # RQPro2.0 - 个人设置 - 数据下载路径    
    
_engine_data_source = FactorEngineDataSource(data_source_path)    
engine = FactorExecutionEngine(_engine_data_source)    
factor = rqfactor.Factor('close')    
order_book_ids = rqdatac.index_components('000300.XSHG')    
end_date = pd.Timestamp('20190910')    
result = engine.get_multiple(factor, order_book_ids, end_date, 1)    
print(result.all())    
    
点击右上角绿色三角形运行 python 代码    

import rqdatac    
rqdatac.init("手机号","密码")    
rqdatac.user.get_quota()    
#{'bytes_used': 742981, #已使用流量    
# 'bytes_limit': 52428800.0, # 总流量    
# 'remaining_days': 760, # 剩余使用天数    
# }    
rqdatac.all_instruments()    
#      order_book_id       symbol  ... listed_date de_listed_date    
#0        M1901P3650  豆粕 1901 沽 3650  ...  2018-04-10     2018-12-07    
#1       SR1901C4900  白糖 1901 购 4900  ...  2018-04-17     2018-11-26    
#2       SR1907C5400  白糖 1907 购 5400  ...  2018-01-17     2019-05-27    
#3        M1907P2900  豆粕 1907 沽 2900  ...  2018-07-17     2019-06-10    
    
rqdatac.instruments("000001.XSHE")    
# Instrument(order_book_id='000001.XSHE', industry_code='J66', market_tplus=1, symbol='平安银行', special_type='Normal', exchange='XSHE', status='Active', type='CS', de_listed_date='0000-00-00', listed_date='1991-04-03', sector_code_name='金融', abbrev_symbol='PAYH', sector_code='Financials', round_lot=100, trading_hours='09:31-11:30,13:01-15:00', board_type='MainBoard', industry_name='货币金融服务', citics_industry_code='40', citics_industry_name='银行')    
    
rqdatac.get_price("000001.XSHE")    
#            num_trades  limit_down       volume  ...   high   open    low    
#date                                             ...                         
#2020-01-10     37440.0       15.11   58554845.0  ...  16.81  16.79  16.52    
#2020-01-13     42233.0       15.02   87213336.0  ...  17.03  16.75  16.61    
#2020-01-14     60290.0       15.29  130449366.0  ...  17.27  16.99  16.76    
#2020-01-15     60129.0       15.08   85943912.0  ...  16.86  16.79  16.4    

titles[0] = codecs.BOM_UTF8.decode("utf8")+codecs.BOM_UTF8.decode()+titles[0]    

import codecs    
import csv    
    
from flask_admin._compat import csv_encode    
from flask import request, redirect, flash, current_app, Response, stream_with_context    

    def _export_csv(self, return_url):    
        """    
            Export a CSV of records as a stream.    
        """    
        count, data = self._export_data()    
    
        # https://docs.djangoproject.com/en/1.8/howto/outputting-csv/    
        class Echo(object):    
            """    
            An object that implements just the write method of the file-like    
            interface.    
            """    
            def write(self, value):    
                """    
                Write the value by returning it, instead of storing    
                in a buffer.    
                """    
                return value    
    
        #    
        writer = csv.writer(Echo())    
    
        def generate():    
            # Append the column titles at the beginning    
            titles = [csv_encode(c[1]) for c in self._export_columns]    
            titles[0] = codecs.BOM_UTF8.decode("utf8")+codecs.BOM_UTF8.decode()+titles[0]    
            yield writer.writerow(titles)    
    
            for row in data:    
                vals = [csv_encode(self.get_export_value(row, c[0]))    
                        for c in self._export_columns]    
                yield writer.writerow(vals)    
    
        filename = self.get_export_name(export_type='csv')    
    
        disposition = 'attachment;filename=%s' % (secure_filename(filename),)    
    
        return Response(    
            stream_with_context(generate()),    
            headers={'Content-Disposition': disposition},    
            mimetype='text/csv'    
        )    

#!/usr/bin/python3    
# encoding: utf-8     
# @Time    : 2020/3/26 15:37    
# @author  : zza    
# @Email   : 740713651@qq.com    
# @File    : readme_helper.py    
import datetime    
import os    
from shutil import copyfile    
    
import markdown    
import markdown.extensions.fenced_code    
from flask import flash, redirect, request, send_from_directory    
from flask_admin import AdminIndexView, expose    
from pygments.formatters.html import HtmlFormatter    
from werkzeug.utils import secure_filename    
    
formatter = HtmlFormatter(style="emacs", full=True, cssclass="codehilite")    
css_string = formatter.get_style_defs()    
    
class MarkdownIndexView(AdminIndexView):    
    
    @expose()    
    def index(self):    
        """获取 readme 文件作为 index 页面帮助文档    
        copy from https://github.com/solitudenote/gitkeeper/blob/d42f5990b05cf28cee12f20780e7794cd3579ead/app.py    
        """    
        # get file    
        readme_file = open("README.md", "r", encoding="utf8")    
        md_template_string = markdown.markdown(readme_file.read(), extensions=["fenced_code", "codehilite"])    
        md_css_string = "<style>" + css_string + "</style>"    
        md_template = md_css_string + md_template_string    
        return self.render(self._template, readme_md=md_template, upload_readme_url="/admin/upload_form")    
    
    @expose('/upload_form', methods=['POST'])    
    def upload_file(self):    
        # check if the post request has the file part    
        if 'file' not in request.files:    
            flash('No file part')    
            return redirect('/admin/')    
        file = request.files['file']    
        if file.filename == '':    
            flash('No file selected for uploading')    
            return redirect('/admin/')    
        if file and file.filename == "README.md":    
            bak_file = "README.md" + ".{}.bak".format(datetime.datetime.now().isoformat()).replace(":", "-")    
            copyfile("README.md", bak_file)    
            filename = secure_filename(file.filename)    
            file.save(filename)    
            flash('README.md 上传成功')    
            return redirect('/admin/')    
        else:    
            flash('文件名必须为 README.md')    
            return redirect('/admin/')    
    
    @expose('/export')    
    def export(self):    
        return send_from_directory(os.path.abspath("."), "README.md", as_attachment=True)  # as_a    
    
admin_index_view = MarkdownIndexView(name="主页", template="index.html")    

from view_markdown_index import admin_index_view    
from flask import Flask    
    
app = Flask(__name__)    
admin_view = Admin(    
    app,    
    template_mode='bootstrap3',    
    index_view=admin_index_view,    
    base_template=r'layout.html',    
    category_icon_classes={'Profiles': 'glyphicon glyphicon-wrench'},    
)    
    
if __name__ == '__main__':    
    app.run()