API-Ebene Geschwindigkeitsbegrenzung nicht in Wso2

Question

Ich benutze Wso2-AM 2.0.0, um eine Begrenzung der Rate für APIs zu erreichen. Ich habe eine API mit einem Benutzer veröffentlicht und sie wird dann von einem anderen Benutzer abonniert. Beim Abonnieren wähle ich eine Abonnementstufe von 20 Anfragen pro Minute für diese API aus. Die Anwendung, die zum Abonnieren der API verwendet wird, hat ein Limit von 50 Anfragen pro Minute. Jetzt, wenn ich die API teste, passiert nach etwa 50 Anfragen nur die Ratenbegrenzung der Anwendungsebene. Das API-Ebenenlimit wird nicht angewendet. Idealerweise sollte der Benutzer nach 20 Anfragen nicht auf die API zugreifen können. Ich verwende Windows-Rechner, um den wso2-Server und Apache JMeter einzurichten, um Anfragen an den Server zu senden. Was fehlt mir hier? Brauchen Sie etwas Hilfe ...

Answer 1

Hier ist eine 4MB/s Politik.

@Plan:name('carbon.super_app_BandwidthPolicy') 
    @Plan:description('ExecutionPlan for app_BandwidthPolicy') 

    @Import('org.wso2.throttle.processed.request.stream:1.0.0') 
    define stream RequestStream (messageID string, appKey string, appTier string, subscriptionKey string, apiKey string, apiTier string, subscriptionTier string, resourceKey string, resourceTier string, userId string, apiContext string, apiVersion string, appTenant string, apiTenant string, appId string, apiName string, propertiesMap string); 

    @Export('org.wso2.throttle.globalThrottle.stream:1.0.0') 
    define stream GlobalThrottleStream (throttleKey string, isThrottled bool, expiryTimeStamp long); 

    FROM RequestStream 
    SELECT messageID, (appTenant == 'carbon.super' and appTier == 'BandwidthPolicy') AS isEligible, appKey AS throttleKey, propertiesMap 
    INSERT INTO EligibilityStream; 

      FROM EligibilityStream[isEligible==true]#throttler:timeBatch(1 min, 0) 
      select throttleKey, (sum(cast(map:get(propertiesMap,'messageSize'),'long')) >= 4194304) as isThrottled, expiryTimeStamp group by throttleKey 
      INSERT ALL EVENTS into ResultStream; 

    from ResultStream#throttler:emitOnStateChange(throttleKey, isThrottled) 
    select * 
    insert into GlobalThrottleStream;