使用 AWS Data Pipeline 将数据从 AWS RDS 移动到 S3

问题描述

我试图将数据从 RDS 移动到 S3 作为备份。我在本地电脑上使用 DBeaver 与 AWS RDS 建立连接并上传一个 csv 文件

然后,我尝试创建数据管道以将数据从 RDS 发送到 S3。最初,我收到错误 DBInstance not found. 但是,当我在“Edit Architect”中提供 DBInstance 的区域时,因为它与数据管道的区域不同,现在,我没有收到该错误

相反,我得到了一个不同的错误错误 ID:ActivityFailed:SocketTimeoutException

error message: connect timed out
errorStackTrace
amazonaws.datapipeline.taskrunner.TaskExecutionException: Error copying record at amazonaws.datapipeline.activity.copy.SingleThreadedcopyActivity.processAll(SingleThreadedcopyActivity.java:65) at amazonaws.datapipeline.activity.copy.SingleThreadedcopyActivity.runActivity(SingleThreadedcopyActivity.java:35) at amazonaws.datapipeline.activity.copyActivity.runActivity(copyActivity.java:22) at amazonaws.datapipeline.objects.AbstractActivity.run(AbstractActivity.java:16) at amazonaws.datapipeline.taskrunner.TaskPoller.executeRemoteRunner(TaskPoller.java:136) at amazonaws.datapipeline.taskrunner.TaskPoller.executeTask(TaskPoller.java:105) at amazonaws.datapipeline.taskrunner.TaskPoller$1.run(TaskPoller.java:81) at private.com.amazonaws.services.datapipeline.poller.PollWorker.executeWork(PollWorker.java:76) at private.com.amazonaws.services.datapipeline.poller.PollWorker.run(PollWorker.java:53) at java.lang.Thread.run(Thread.java:748) Caused by: java.lang.RuntimeException: com.MysqL.jdbc.exceptions.jdbc4.CommunicationsException: Communications link failure The last packet sent successfully to the server was 0 milliseconds ago. The driver has not received any packets from the server. at private.com.google.common.base.Throwables.propagate(UnkNown Source) at amazonaws.datapipeline.database.ConnectionFactory.getConnection(ConnectionFactory.java:192) at amazonaws.datapipeline.database.ConnectionFactory.getConnection(ConnectionFactory.java:177) at amazonaws.datapipeline.database.ConnectionFactory.getRdsDatabaseConnection(ConnectionFactory.java:161) at amazonaws.datapipeline.database.ConnectionFactory.getConnection(ConnectionFactory.java:73) at amazonaws.datapipeline.database.ConnectionFactory.getConnectionWithCredentials(ConnectionFactory.java:301) at amazonaws.datapipeline.connector.sqlDatanode.createConnection(sqlDatanode.java:100) at amazonaws.datapipeline.connector.sqlDatanode.getConnection(sqlDatanode.java:94) at amazonaws.datapipeline.connector.sqlDatanode.prepareStatement(sqlDatanode.java:162) at amazonaws.datapipeline.connector.sqlInputConnector.open(sqlInputConnector.java:48) at amazonaws.datapipeline.connector.sqlInputConnector.<init>(sqlInputConnector.java:25) at amazonaws.datapipeline.connector.sqlDatanode.getInputConnector(sqlDatanode.java:79) at amazonaws.datapipeline.activity.copy.SingleThreadedcopyActivity.processAll(SingleThreadedcopyActivity.java:47) ... 9 more Caused by: com.MysqL.jdbc.exceptions.jdbc4.CommunicationsException: Communications link failure The last packet sent successfully to the server was 0 milliseconds ago. The driver has not received any packets from the server. at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method) at sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:57) at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45) at java.lang.reflect.Constructor.newInstance(Constructor.java:527) at com.MysqL.jdbc.Util.handleNewInstance(Util.java:404) at com.MysqL.jdbc.sqlError.createCommunicationsException(sqlError.java:988) at com.MysqL.jdbc.MysqLIO.<init>(MysqLIO.java:341) at com.MysqL.jdbc.ConnectionImpl.coreConnect(ConnectionImpl.java:2251) at com.MysqL.jdbc.ConnectionImpl.connectOneTryOnly(ConnectionImpl.java:2284) at com.MysqL.jdbc.ConnectionImpl.createNewIO(ConnectionImpl.java:2083) at com.MysqL.jdbc.ConnectionImpl.<init>(ConnectionImpl.java:806) at com.MysqL.jdbc.JDBC4Connection.<init>(JDBC4Connection.java:47) at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method) at sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:57) at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45) at java.lang.reflect.Constructor.newInstance(Constructor.java:527) at com.MysqL.jdbc.Util.handleNewInstance(Util.java:404) at com.MysqL.jdbc.ConnectionImpl.getInstance(ConnectionImpl.java:410) at com.MysqL.jdbc.NonRegisteringDriver.connect(NonRegisteringDriver.java:328)

谁能指导我问题出在哪里?

问候

解决方法

暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!

如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@)