你好,
我在Azure磚,我創建了兩個工作,一個基於python輪和其他基於一個筆記本,使用相同的代碼。代碼從Azure blob存儲獲取數據,處理數據和pyspark EventHub發送數據。整個代碼封裝在一個try /除,像這樣:
#從opencensus.ext.azure導入庫。log_exporter導入AzureLogHandler導入日誌#添加之前def主要(). .日誌記錄器= logging.getLogger ()。addHandler (AzureLogHandler (connection_string = ' my-connection-string ')) if __name__ = =“__main__”:試題:主要()#主要代碼:獲取數據,處理數據,將數據發送給eventhub除了異常e:味精= str (getattr (e,‘消息’,repr (e))) logger.exception(味精)
我試圖生成一個異常測試登錄應用見解為基於輪工作,筆記本電腦工作,我注意到,即使他們工作得很好第一個(輪工作)回報”失敗的“最後,而不是第二個(筆記本工作)回報”成功”。
有人知道為什麼行為變化與工作“格式”?
謝謝你的幫助!
