관련 기사:https://www.fmz.com/bbs-topic/5969
HTTPS서버 자체에는 몇 가지 문제점이 있기 때문에, 대신 THREADINGHTTPSERVER를 사용하는 것을 고려하십시오. 참고:https://docs.python.org/3.7/library/http.server.htmlPython 3.7 버전이 필요합니다.
HTTPServer 문제에 대한 정보:https://www.zybuluo.com/JunQiu/note/1350528
'''
请求格式：http://x.x.x.x:xxxx/data?access_key=xxx&secret_key=yyy&type=buy&amount=0.001
策略机器人参数：
- 类型：加密字符串，AccessKey , SecretKey ，可以用FMZ平台的低权限的API KEY，或者自己生成KEY也可以。
- 类型：字符串，合约ID，ContractType
- 类型：数值，端口号，Port
'''
import re
import _thread
import json
from http.server import ThreadingHTTPServer, BaseHTTPRequestHandler
from urllib.parse import parse_qs, urlparse
def url2Dict(url):
query = urlparse(url).query
params = parse_qs(query)
result = {key: params[key][0] for key in params}
return result
class Executor(BaseHTTPRequestHandler):
def do_GET(self):
try:
dictParam = url2Dict(self.path)
Log("测试", dictParam)
except Exception as e:
Log("Provider do_GET error, e:", e)
def do_POST(self):
try:
self.send_response(200)
self.send_header("Content-type", "application/json")
self.end_headers()
dictParam = url2Dict(self.path)
# 测试POST请求Body信息
data = self.rfile.read(200) # 指定了读取长度
Log("data:", data) # 打印POST请求的数据，可以根据请求中的数据具体再让机器人执行对应的操作
# 校验
if len(dictParam) == 4 and dictParam["access_key"] == AccessKey and dictParam["secret_key"] == SecretKey:
del dictParam["access_key"]
del dictParam["secret_key"]
Log("接收到请求", "参数：", dictParam, "#FF0000")
'''
map[access_key:xxx amount:0.001 secret_key:yyy type:buy]
'''
isSpot = True
if exchange.GetName().find("Futures") != -1:
if ContractType != "":
exchange.SetContractType(ContractType)
isSpot = False
else :
raise "未设置期货合约"
q = None
if exchange.GetName() == "Futures_CTP" and UseMarketOrderForCTP == False:
q = ext.NewTaskQueue()
if isSpot and dictParam["type"] == "buy":
exchange.Buy(-1, float(dictParam["amount"]))
Log(exchange.GetAccount())
elif isSpot and dictParam["type"] == "sell":
exchange.Sell(-1, float(dictParam["amount"]))
Log(exchange.GetAccount())
elif not isSpot and dictParam["type"] == "long":
exchange.SetDirection("buy")
if not q:
exchange.Buy(-1, float(dictParam["amount"]))
else :
q.pushTask(exchange, ContractType, "buy", float(dictParam["amount"]), lambda task, ret: Log(task["desc"], ret, "#FF0000"))
Log("持仓：", exchange.GetPosition())
elif not isSpot and dictParam["type"] == "short":
exchange.SetDirection("sell")
if not q:
exchange.Sell(-1, float(dictParam["amount"]))
else :
q.pushTask(exchange, ContractType, "sell", float(dictParam["amount"]), lambda task, ret: Log(task["desc"], ret, "#FF0000"))
Log("持仓：", exchange.GetPosition())
elif not isSpot and dictParam["type"] == "cover_long":
exchange.SetDirection("closebuy")
if not q:
exchange.Sell(-1, float(dictParam["amount"]))
else :
q.pushTask(exchange, ContractType, "closebuy", float(dictParam["amount"]), lambda task, ret: Log(task["desc"], ret, "#FF0000"))
Log("持仓：", exchange.GetPosition())
elif not isSpot and dictParam["type"] == "cover_short":
exchange.SetDirection("closesell")
if not q:
exchange.Buy(-1, float(dictParam["amount"]))
else :
q.pushTask(exchange, ContractType, "closesell", float(dictParam["amount"]), lambda task, ret: Log(task["desc"], ret, "#FF0000"))
Log("持仓：", exchange.GetPosition())
if q is not None:
while q.size() > 0:
q.poll()
Sleep(500)
# 处理body数据
if isDealBodyMsg:
if exchange.GetName().find("Futures") != -1:
Log("data:", data.decode('utf-8')) # 测试
if re.search(r'buy', data.decode('utf-8')):
Log("触发buy")
exchange.SetContractType(ct)
exchange.SetDirection("buy")
exchange.Buy(-1, amount)
elif re.search(r'sell', data.decode('utf-8')):
Log("触发sell")
exchange.SetContractType(ct)
exchange.SetDirection("sell")
exchange.Sell(-1, amount)
# 写入数据应答
self.wfile.write(json.dumps({"state": "ok"}).encode())
except Exception as e:
Log("Provider do_POST error, e:", e)
def createServer(host):
try:
server = ThreadingHTTPServer(host, Executor)
Log("Starting server, listen at: %s:%s" % host)
server.serve_forever()
except Exception as e:
Log("createServer error, e:", e)
raise Exception("stop")
def main():
# 开启一个线程
try:
_thread.start_new_thread(createServer, (("0.0.0.0", Port), )) # VPS服务器上测试
except Exception as e:
Log("错误信息：", e)
raise Exception("stop")
if exchange.GetName().find("Futures") != -1:
exchange.SetContractType(ContractType)
Log("账户资产信息：", _C(exchange.GetAccount))
while True:
if exchange.GetName() == "Futures_CTP":
if exchange.IO("status"):
LogStatus(_D(), "CTP连接")
else:
LogStatus(_D(), "CTP未连接")
else:
LogStatus(_D())
Sleep(2000)
eth8888/upload/asset/2457669d9c32568732cb7.jpg 디스크를 열면 이 오류가 나타납니다.
eth8888/upload/asset/2457669d9c32568732cb7.jpg 디스크를 열면 이 오류가 나타납니다.
화산의 검선생님: 微信을 넣을 수 있나요?
화산의 검2021/11/21 11:53:33 CMD 199866 buy=0.1, 관리자가 이 메시지를 받았지만 로봇은 아무런 동작도 하지 않았습니다.
수퍼온V:maybeyeah. V:maybeyeah. V:maybeyeah. V:maybeyeah.
다이어트 퀀트선생님, 어떻게 하면 이중화폐를 더할 수 있을까요?
꿈은 8자리입니다.오케이, OKv5 모형판을 만들 수 있나요?
ssxxx선생님, 3.7 버전은 관리자 버전인가요? 어떻게 업데이트할 수 있나요?
2021-08-11 11:08:55 오류 트레이스백 (most recent call last): 파일 "
qq3390214355한밤중에 봤는데 이해가 안되는데, 어떻게 연락할 수 있는지 다시 써주실 수 있나요?
첸나센선생님 안녕하세요, TV에서 직접 경고 거래 방향에 대한 전략 웹
란브좋아요, 감사합니다 선생님, 제가 테스트해 보겠습니다!
란브선생님, 안녕하세요, 계약에 대한 코드를 좀 더 자세히 설명해 주시겠습니까?
발명가들의 수량화 - 작은 꿈FMZ API 문서는 마지막으로 OKEX 스위치 모형 디스크의 함수를 가지고 있다.
N95TV 신호를 수신하는 전략, 어떻게 아날로그 디스크를 전환합니까?
발명가들의 수량화 - 작은 꿈오류는 python에 관련된 모듈이 없기 때문입니다.
키986이 문제를 해결하지 않았나요?
eth8888이 문제를 해결했습니다.
발명가들의 수량화 - 작은 꿈TV를 감청할 수 있는 서비스를 만드는 것은 권장하지 않습니다. FMZ의 확장 API를 사용하세요.
발명가들의 수량화 - 작은 꿈이 전략은 상품 선물의 예로, 디지털 화폐를 실행하려면 계약 코드를 설정해야 합니다.
발명가들의 수량화 - 작은 꿈이 전략의 예는 직결된 것으로, 전략 로봇이 TV로부터 신호 요청을 듣기 위해 서비스를 구축하는 것입니다. `` # POST을 테스트합니다. data = self.rfile.read ((200) # 읽기 길이를 지정합니다 Log (("data:", data) # POST 요청의 데이터를 인쇄하여 요청의 데이터에 따라 로봇이 해당 작업을 수행하도록 할 수 있습니다. `` 이 코드는 이미 코드에 언급되어 있습니다. 여기 TV의 요청을 처리하는 body 정보입니다.
발명가들의 수량화 - 작은 꿈이 모든 것은 그들의 필요에 따라 전략을 수정하는 것입니다.
발명가들의 수량화 - 작은 꿈FMZ에서 OKEX 모형 디스크를 구성하는 API KEY, 그리고 코드에 `` ` 교환을 추가하면, IO (simulate, true) ` ` 교환이 완료됩니다.
발명가들의 수량화 - 작은 꿈이 글은 한글로 번역되어 있습니다.
첸나센감사합니다, 만약 제 웹후크 주소가 거래 방향이 구매라고 적혀있다면, 하지만 tv 전략 경보의 팁은 판매하는 것입니다.
발명가들의 수량화 - 작은 꿈https://www.fmz.com/bbs-topic/5969 기사와 전략에는 예가 있습니다.
발명가들의 수량화 - 작은 꿈https://www.fmz.com/api#exchange.setcontracttype... 함수 설명에 있습니다.
PY008계약 코드란 무엇입니까?
발명가들의 수량화 - 작은 꿈이 모든 것은 매우 무례합니다.
발명가들의 수량화 - 작은 꿈만약 거래소와 계약을 하고 있다면 TV의 웹후크 주소를 이렇게 적어주세요. 다른 계약: `` http://x.x.x.x:xxxx/data?access_key=xxx&secret_key=yyy&type=long&amount=1 `` 이 모든 것은 단지 하나의 계약에 불과합니다. `` http://x.x.x.x:xxxx/data?access_key=xxx&secret_key=yyy&type=cover_long&amount=1 `` 이 문서는 이 문장의 문장과 같은 문장입니다.