限制 Ember 数据请求
Throttling Ember Data requests
我正在使用 Ember 数据与具有速率限制的 REST API 进行交互。
关于如何将 Ember 数据请求限制为每秒 X 请求有什么建议吗?
经过一些努力,我设法让 promise-throttle 在我的 ApplicationController
中工作。限制为每秒 4 个请求:
import PromiseThrottle from 'dispatcher/application/promise-throttle';
import { Promise } from 'rsvp';
export default DS.RESTAdapter.extend(DataAdapterMixin, {
init() {
this.set('promiseThrottle', new PromiseThrottle({
requestsPerSecond: 4,
promiseImplementation: Promise
}));
},
ajax: function (url, type, options) {
return this.get('promiseThrottle').add(this._super.bind(this, url, type, options));
}
...
});
首先,如果你想用 all AJAX 请求做事,我强烈推荐 ember-ajax
。这使您可以通过一个点来修改所有 AJAX 请求。接下来关于节流。我在评论中建议 ember-concurrency
,所以让我详细说明一下。 ember-concurrency
给你一个 timeout
方法,即 returns 一个将在一定时间后解决的承诺。这允许轻松节流:
export default AjaxService.extend({
ajaxThrottle: task(function * (cb) {
cb();
// maxConcurrency with timeout 1000 means at maximum 3 requests per second.
yield timeout(1000);
}).maxConcurrency(3).enqueue(),
async request() {
await new Promise(cb => ajaxThrottle.perform(cb));
return this._super(...arguments); // this should make the actual request
},
});
我正在使用 Ember 数据与具有速率限制的 REST API 进行交互。
关于如何将 Ember 数据请求限制为每秒 X 请求有什么建议吗?
经过一些努力,我设法让 promise-throttle 在我的 ApplicationController
中工作。限制为每秒 4 个请求:
import PromiseThrottle from 'dispatcher/application/promise-throttle';
import { Promise } from 'rsvp';
export default DS.RESTAdapter.extend(DataAdapterMixin, {
init() {
this.set('promiseThrottle', new PromiseThrottle({
requestsPerSecond: 4,
promiseImplementation: Promise
}));
},
ajax: function (url, type, options) {
return this.get('promiseThrottle').add(this._super.bind(this, url, type, options));
}
...
});
首先,如果你想用 all AJAX 请求做事,我强烈推荐 ember-ajax
。这使您可以通过一个点来修改所有 AJAX 请求。接下来关于节流。我在评论中建议 ember-concurrency
,所以让我详细说明一下。 ember-concurrency
给你一个 timeout
方法,即 returns 一个将在一定时间后解决的承诺。这允许轻松节流:
export default AjaxService.extend({
ajaxThrottle: task(function * (cb) {
cb();
// maxConcurrency with timeout 1000 means at maximum 3 requests per second.
yield timeout(1000);
}).maxConcurrency(3).enqueue(),
async request() {
await new Promise(cb => ajaxThrottle.perform(cb));
return this._super(...arguments); // this should make the actual request
},
});