@Sanjoy森:
是的,它是可以從DataFrame加載數據到Azure存儲隊列/消息隊列。這是一個可能的方法:
這裏有一些示例代碼開始:
從azure.storage進口json。隊列進口QueueClient # DataFrame轉換為一個JSON字符串json_data = df.toJSON () .collect() #客戶創建一個隊列對象queue_client = QueueClient.from_connection_string (conn_str = <連接字符串>,queue_name = < your-queue-name >) #將JSON字符串作為消息發送到隊列中的數據json_data:消息= json.dumps(數據)queue_client.send_message(消息)
在上麵的代碼中,用的連接字符串替換<連接字符串> Azure存儲賬戶和< your-queue-name >您的隊列的名稱。另外,確保處理過程中可能發生的任何錯誤或異常消息發送過程。
@Sanjoy森:
是的,它是可以從DataFrame加載數據到Azure存儲隊列/消息隊列。這是一個可能的方法:
這裏有一些示例代碼開始:
從azure.storage進口json。隊列進口QueueClient # DataFrame轉換為一個JSON字符串json_data = df.toJSON () .collect() #客戶創建一個隊列對象queue_client = QueueClient.from_connection_string (conn_str = <連接字符串>,queue_name = < your-queue-name >) #將JSON字符串作為消息發送到隊列中的數據json_data:消息= json.dumps(數據)queue_client.send_message(消息)
在上麵的代碼中,用的連接字符串替換<連接字符串> Azure存儲賬戶和< your-queue-name >您的隊列的名稱。另外,確保處理過程中可能發生的任何錯誤或異常消息發送過程。