taskqueues 예시에서 마이그레이션하기 위한 큐 업데이트
코드 샘플
자바
Cloud Tasks용 클라이언트 라이브러리를 설치하고 사용하는 방법은 Cloud Tasks 클라이언트 라이브러리를 참조하세요.
import com.google.cloud.tasks.v2.CloudTasksClient;
import com.google.cloud.tasks.v2.LocationName;
import com.google.cloud.tasks.v2.Queue;
import com.google.cloud.tasks.v2.QueueName;
import com.google.cloud.tasks.v2.RateLimits;
import com.google.cloud.tasks.v2.UpdateQueueRequest;
public class UpdateQueue {
public static void updateQueue(String projectId, String locationId, String queueId)
throws Exception {
try (CloudTasksClient client = CloudTasksClient.create()) {
// TODO(developer): Uncomment these lines and replace with your values.
// String projectId = "your-project-id";
// String locationId = "us-central1";
// String queueId = "queue-blue";
LocationName parent = LocationName.of(projectId, locationId);
Queue queueBlue =
Queue.newBuilder()
.setName(QueueName.of(projectId, locationId, queueId).toString())
.setRateLimits(
RateLimits.newBuilder()
.setMaxDispatchesPerSecond(20.0)
.setMaxConcurrentDispatches(10))
.build();
UpdateQueueRequest request = UpdateQueueRequest.newBuilder().setQueue(queueBlue).build();
Queue response = client.updateQueue(request);
System.out.println(response);
}
}
}
Python
Cloud Tasks용 클라이언트 라이브러리를 설치하고 사용하는 방법은 Cloud Tasks 클라이언트 라이브러리를 참조하세요.
client = tasks.CloudTasksClient()
# TODO(developer): Uncomment these lines and replace with your values.
# project = 'my-project-id'
# location = 'us- central1'
# queue = 'queue-blue'
# Get queue object
queue_path = client.queue_path(project, location, queue)
queue = client.get_queue(name=queue_path)
# Update queue object
queue.rate_limits.max_dispatches_per_second = 20
queue.rate_limits.max_concurrent_dispatches = 10
response = client.update_queue(queue=queue)
print(response)