내 앱에서 이벤트가 발생하면 많은 사용자에게 이메일을 보내야합니다. 한 번에 모든 이메일을 보내지 않고 서서히 메일을 보내고 싶습니다. 설명을 명확히하기 위해 10,000 명의 사용자에게 이메일을 보내야한다고 가정 해 보겠습니다. 현재 작업 속도는 최대 1 작업/초인 작업 대기열에서 수행합니다. 일괄 작업으로 10,000 개의 작업을 대기열에 넣었으며 이메
내가 파이썬이 무한한 루프의 모든 초 Google TaskQueue REST API에서 프로세스 임대 작업 : credentials = GoogleCredentials.get_application_default()
task_api = googleapiclient.discovery.build('taskqueue', 'v1beta2', credentials=
Windows Server의 Microsoft Message Queue에서 새로운 기능인 경우 EmployeeID가 NULL이면 밀어 넣어야합니다. 데이터가 검증 예외 큐에 가압되면 직원 모델 클래스 public class Employee
{
public string EmployeeID { get; set; }
public string
많은 인기있는 작업 대기열 (예 : Google GAE TaskQueue, Celery)에는 ETA/Countdown 기능이있어 xxx 초 후에 대기열에 작업을 넣을 수 있습니다. ETA 기능이있는 작업 대기열이 필요한 프로젝트에서 작업 중입니다. 그러나 Google Pubsub 메시징 시스템을 사용해야하는 몇 가지 제한 사항이 있습니다. Pubsub에는
일부 장기 실행 작업을 수행하기 위해 Google 클라우드 작업 대기열을 사용하고 있습니다. 모든 작업이 완료되면 알림을 보내려고합니다. 나는 QueueStatistics 통계 = taskQueue.fetchStatistics() 내 스레드에서 대기중인 작업의 번호를 코드 아래 사용하고 있습니다; stats.getNumTasks(); 하지만 여기서는 get
그래서 내 API에는 프로세스/보고서가 실행되는 시간 제한이 있거나 몇 분이 걸리는 곳이 몇 군데 있습니다. 이 작업을 대기열로 연기하고 대신 내 응답에서 키를 반환하고 싶습니다. 그런 다음 프런트 엔드는 해당 키를 사용하여 대기열에서 특정 작업의 상태를 확인하는 서비스를 ping합니다. 이렇게하면 우리는 아약스를 교수형에 처하지 않고 2 ~ 3 분 동안
RabbitMQ와 같은 메시지 브로커는 서로 다른 언어/플랫폼으로 작성된 서로 다른 응용 프로그램이 서로 통신 할 수 있도록 도와줍니다. 셀러리가 메시지 브로커로 RabbitMQ를 사용할 수 있기 때문에, 프로듀서가 파이썬으로 작성되지 않았더라도 셀러리에게 어떤 애플리케이션의 작업도 대기시킬 수 있다고 생각합니다. 이제 RabbitMQ를 통해 C#으로 작성
현재 appengine에서 실행중인 애플리케이션이 있으며 지연 라이브러리를 사용하여 몇 가지 작업을 실행하고 있습니다. 일부 작업은 매일 실행되지만 일부 작업은 한 달에 한 번 실행됩니다. 이러한 작업의 대부분은 Datastore를 쿼리하여 문서를 검색 한 다음 엔티티를 색인 (검색 API)에 저장합니다. 이 테이블 중 일부는 매월 교체되며 모든 엔티티에서
지연 작업 대기열에서 일부 작업을 수행하려고하고 지연 대기열에서 작업 완료에 성공해야하는 다른 작업을 실행해야합니다. 예를 들어, 특정 경로에 저장된 모든 파일을 삭제해야하고 나중에 파일을 다시 만들려고하는 모든 파일을 성공적으로 삭제 한 후에 필요합니다. 다음은 현재이를 달성하기위한 샘플 코드입니다. 불행하게도, 그것은 다음과 같은 예외가 발생 : rai
Twitter API를 사용하는 것에 대해 node.js로 애플리케이션을 작성하고 있습니다. 다음과 같은 기능 : app.get('/api/get_follower', function(req, res){
var username = req.query.username
var client = new twitter({
consumer_k