azure ADF将活动从Oracle复制到ASQL -记录失败错误SessionLogFailToWriteLog

5rgfhyps  于 2023-04-22  发布在  Oracle
关注(0)|答案(1)|浏览(152)

我有现有的管道从Oracle复制数据到Azure SQL成功执行。然后添加了级别=警告和模式=可靠的日志记录,请参阅下文。但管道在源处卡住并最终失败,因为管道超时设置为15分钟。收到的错误消息如下。
我是否错过了一些配置?请提供一些建议,为什么会这样,谢谢!
ADF日志记录设置

在源复制失败

Operation on target AC_COPY_SRC_TO_STG failed: ErrorCode=SessionLogFailToWriteLog,'Type=Microsoft.DataTransfer.Common.Shared.HybridDeliveryException,Message=Write log is failed with error message: 'Microsoft.DataTransfer.Common.Shared.HybridDeliveryException: ADLS Gen2 operation failed for: An error occurred while sending the request.. Account: 'storageAccount'. FileSystem: 'raw'.. ---> System.Net.Http.HttpRequestException: An error occurred while sending the request. ---> System.Net.WebException: Unable to connect to the remote server ---> System.Net.Sockets.SocketException: A connection attempt failed because the connected party did not properly respond after a period of time, or established connection failed because connected host has failed to respond 10.41.33.170:443
   at System.Net.Sockets.Socket.InternalEndConnect(IAsyncResult asyncResult)
   at System.Net.Sockets.Socket.EndConnect(IAsyncResult asyncResult)
   at System.Net.ServicePoint.ConnectSocketInternal(Boolean connectFailure, Socket s4, Socket s6, Socket& socket, IPAddress& address, ConnectSocketState state, IAsyncResult asyncResult, Exception& exception)
   --- End of inner exception stack trace ---
   at System.Net.HttpWebRequest.EndGetResponse(IAsyncResult asyncResult)
   at System.Net.Http.HttpClientHandler.GetResponseCallback(IAsyncResult ar)
   --- End of inner exception stack trace ---
   at System.Runtime.ExceptionServices.ExceptionDispatchInfo.Throw()
   at Microsoft.Rest.RetryAfterDelegatingHandler.<SendAsync>d__7.MoveNext()
--- End of stack trace from previous location where exception was thrown ---
   at System.Runtime.ExceptionServices.ExceptionDispatchInfo.Throw()
   at System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(Task task)
   at Microsoft.Rest.RetryDelegatingHandler.<>c__DisplayClass15_0.<<SendAsync>b__0>d.MoveNext()
--- End of stack trace from previous location where exception was thrown ---
   at System.Runtime.ExceptionServices.ExceptionDispatchInfo.Throw()
   at System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(Task task)
   at Microsoft.Rest.RetryDelegatingHandler.<SendAsync>d__15.MoveNext()
--- End of stack trace from previous location where exception was thrown ---
   at System.Runtime.ExceptionServices.ExceptionDispatchInfo.Throw()
   at System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(Task task)
   at Microsoft.Azure.Storage.Data.RequestHandler.<SendAsync>d__3.MoveNext()
--- End of stack trace from previous location where exception was thrown ---
   at System.Runtime.ExceptionServices.ExceptionDispatchInfo.Throw()
   at System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(Task task)
   at Microsoft.Azure.Storage.Data.AzureDfsClient.<GetFilesystemPropertiesWithHttpMessagesAsync>d__42.MoveNext()
--- End of stack trace from previous location where exception was thrown ---
   at System.Runtime.ExceptionServices.ExceptionDispatchInfo.Throw()
   at System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(Task task)
   at Microsoft.Azure.Storage.Data.AzureDfsClientExtensions.<GetFilesystemPropertiesAsync>d__14.MoveNext()
--- End of stack trace from previous location where exception was thrown ---
   at System.Runtime.ExceptionServices.ExceptionDispatchInfo.Throw()
   at System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(Task task)
   at Microsoft.Azure.Storage.Data.AzureDfsClientExtensions.GetFilesystemProperties(IAzureDfsClient operations, String filesystem, String resource, String xMsClientRequestId, Nullable`1 timeout, String xMsDate)
   at Microsoft.Azure.Storage.Data.BlobFSClient.<>c__DisplayClass32_0.<IsFileSystemExist>b__1()
   at Microsoft.Rest.TransientFaultHandling.RetryPolicy.ExecuteAction[TResult](Func`1 func)
   at Microsoft.Azure.Storage.Data.BlobFSClient.<>c__DisplayClass32_0.<IsFileSystemExist>b__0()
   at Microsoft.Azure.Storage.Data.ExceptionHandler.ExecuteAction[TResult](Func`1 func, String fileSystem, String path, String actionName)
   --- End of inner exception stack trace ---
   at Microsoft.Azure.Storage.Data.ExceptionHandler.HandleException(Exception ex, String fileSystem, String path, String actionName)
   at Microsoft.Azure.Storage.Data.ExceptionHandler.ExecuteAction[TResult](Func`1 func, String fileSystem, String path, String actionName)
   at Microsoft.Azure.Storage.Data.BlobFSClient.IsFileSystemExist(String filesystem, Boolean swallowForbiddenError, Boolean useListPathApi)
   at Microsoft.Azure.Storage.Data.BlobFSClient.CreateFileSystemIfNotExist(String filesystem, Boolean swallowForbiddenError, Boolean useListPathApiToCheckFileSystemExist)
   at Microsoft.DataTransfer.Runtime.BlobFSMultipartSink..ctor(AzureBlobFSConnection connection, AzureBlobFSWriteInternalSettings writeSettings)
   at Microsoft.DataTransfer.Runtime.AzureBlobFSConnection.CreateSink(IDictionary`2 properties)
   at Microsoft.DataTransfer.Runtime.BinarySinkStageProcessor..ctor(PluginRegistration plugins, IDictionary`2 stageProperties, BinaryTelemetryCollector telemetryCollector)
   at Microsoft.DataTransfer.Runtime.Provider.HybirdRuntimeBinaryWriter.<>c__DisplayClass11_0.<ProcessCommandSettings>b__1()
   at Microsoft.DataTransfer.Runtime.PipelineProcessStage`3.CreateProcessor(Func`1 createNextProcessor)
   at Microsoft.DataTransfer.Runtime.PipelineProcessStageProcessor`2.Process(TInput data)
   at Microsoft.DataTransfer.Runtime.Provider.HybridRuntimeCommand.ExecuteBinaryWriter(IEnumerable`1 data)
   at Microsoft.DataTransfer.Runtime.FileBasedLogHandler.CreateEmptyLogFile(Int32 currFileIndex)'.,Source=Microsoft.DataTransfer.ClientLibrary,'

我尝试禁用日志记录,管道再次成功。

bnlyeluc

bnlyeluc1#

通过查看您面临的错误,可能是因为数据工厂无法与ADLS通信。错误消息还表明,该问题可能与无法连接到IP地址为“www.example.com”的特定服务器10.41.33.170有关。
要解决此问题,请执行以下操作:

  • 检查以确保ADLS Gen2帐户设置正确且可访问。
  • 验证应用程序和ADLS Gen2帐户的网络连接。
  • 检查防火墙规则是否阻止访问IP为10.41.33.170的服务器。
    您可以在存储账户防火墙中添加此地址,具体操作如下:

我也尝试了类似的设置,它对我来说工作正常。

相关问题