天天看點

【Azure 存儲服務】關于Storage Account Queue使用的幾個問題

1) 在消費Storage Queue中的資料的時候,如何隻過濾出 Subject 為”message/{messageid}”這種,去掉subject為”information/{infoid}”這種資料呢?

【答】:因為Storage Queue中并沒有Filter功能,是以不能再擷取消息時候,再Storage Queue服務端進行過濾。隻能由用戶端擷取到全部消息後,對消息中資料進行解析并過濾處理。這需要在receiveMessages 代碼塊中處理。

2) Storage Queue側如何設定資料的過期時間(目前看到過去時間為7天,希望可以設定的更久)

【答】:在門戶上添加消息時,現在隻能設定7天或者是Never Expires。 但是在代碼中,您可以設定更長的時間。如:Duration timeToLive = Duration.ofDays(11);

【Azure 存儲服務】關于Storage Account Queue使用的幾個問題

Java 示例代碼片段

// Instantiate a QueueClient which will be
        // used to create and manipulate the queue
        QueueClient queueClient = new QueueClientBuilder()
                .connectionString(connectStr)
                .queueName(queueName)
                .buildClient();

        // // Create the queue
        // queueClient.create();
        System.out.println("\nAdding messages to the queue...");
        for (int i = 0; i < 10; i++) {
            Duration timeToLive = Duration.ofDays(11);
            Duration timeout =Duration.ofSeconds(20);
            queueClient.sendMessageWithResponse("messageText is " +i, null, timeToLive, timeout, null);
        }       
【Azure 存儲服務】關于Storage Account Queue使用的幾個問題

3) Storage Queue側有沒有關于容量,費用等的一些限制呢?

【答】單個Storage Queue容量的總限制在500TB,消息的大小為64KB,其他的限制見:https://docs.azure.cn/zh-cn/storage/queues/scalability-targets#scale-targets-for-queue-storage ,費用的計算可參考價格部分:https://www.azure.cn/pricing/details/storage/queues/

【Azure 存儲服務】關于Storage Account Queue使用的幾個問題

4) 通過Java code是否可以直接從Storage queue 拉取資料到mysql資料庫。 

【答】可以的,需要在接收代碼塊中,可以添加寫入MySQL的代碼,完成資料輸入資料庫。

【Azure 存儲服務】關于Storage Account Queue使用的幾個問題

Source: https://docs.azure.cn/zh-cn/storage/queues/storage-quickstart-queues-java?tabs=powershell%2Cenvironment-variable-windows#receive-and-delete-messages-from-a-queue

【END】

當在複雜的環境中面臨問題,格物之道需:濁而靜之徐清,安以動之徐生。 雲中,恰是如此!

繼續閱讀