TA.MOM()

TA.MOM(data, timeperiod=10)

def main():
    records = exchange.GetRecords()
    closes = [r['Close'] for r in records]
    
    mom = TA.MOM(closes, 10)
    
    Log(f"动量值: {mom[-1]:.2f}")
    
    if mom[-1] > 0:
        Log("价格上升动能")
    else:
        Log("价格下降动能")
    
    # 穿越零线
    if mom[-1] > 0 and mom[-2] <= 0:
        Log("动量指标上穿零线，买入信号")
    elif mom[-1] < 0 and mom[-2] >= 0:
        Log("动量指标下穿零线，卖出信号")

def main():
    records = exchange.GetRecords()
    closes = [r['Close'] for r in records]
    
    mom = TA.MOM(closes, 10)
    
    # 动能变化率（加速度）
    mom_change = mom[-1] - mom[-2]
    
    if mom[-1] > 0 and mom_change > 0:
        Log("上升动能加速")
    elif mom[-1] > 0 and mom_change < 0:
        Log("上升动能减速，可能见顶")
    elif mom[-1] < 0 and mom_change < 0:
        Log("下降动能加速")
    elif mom[-1] < 0 and mom_change > 0:
        Log("下降动能减速，可能见底")

def detect_mom_divergence(prices, mom_values, period=10):
    """检测动量背离"""
    if len(prices) < period or len(mom_values) < period:
        return None
    
    # 顶背离
    if (prices[-1] > max(prices[-period:-1]) and 
        mom_values[-1] < max(mom_values[-period:-1])):
        return "顶背离"
    
    # 底背离
    if (prices[-1] < min(prices[-period:-1]) and 
        mom_values[-1] > min(mom_values[-period:-1])):
        return "底背离"
    
    return None

def main():
    records = exchange.GetRecords()
    closes = [r['Close'] for r in records]
    
    mom = TA.MOM(closes, 10)
    divergence = detect_mom_divergence(closes, mom)
    
    if divergence:
        Log(f"动量指标{divergence}")

mom = TA.MOM(closes, 10)
ma = TA.MA(closes, 20)

# 动量确认趋势
if mom[-1] > 0 and closes[-1] > ma[-1]:
    Log("上升趋势 + 正动量")