AWS Kinesis从过去读取
我们如何从AWS的运动流中读回时间
使用AWS Kinesis stream，可以发送事件流，消费者应用程序可以读取事件。Kinesis Stream worker从最后一个检查点获取记录并将其传递给IRecordProcessor#processRecords
但是，如果我需要读取回溯到时间的记录，例如从2小时前开始处理记录，我如何配置我的运动工作者来获取这些记录？
共有1个答案
您可以使用有关碎片迭代器的不同设置再次启动您的kinesis消费者（或另一个）。请参见此处GetShardIterator通常设置为最新或TRIM\u HORIZON（最旧）：
{
"ShardId": "ShardId",
"ShardIteratorType": "LATEST",
"StreamName": "StreamName",
}
但您可以将其更改为特定时间（从过去24小时开始）
{
"ShardId": "ShardId",
"ShardIteratorType": "AT_TIMESTAMP",
"StreamName": "StreamName",
"Timestamp": 2016-06-29T19:58:46.480-00:00
}
请记住，通常运动消费者将其检查点保存在Dynamodb表中，因此如果您使用相同的运动应用程序，您需要先删除这些检查点。
-
在revert可以取消指定的提交内容。使用后面要提到的rebase -i或reset也可以删除提交。但是，不能随便删除已经发布的提交，这时需要通过revert创建要否定的提交。 主要使用的场合： 安全地取消过去发布的提交
-
问题内容： 我正在尝试在Go中创建服务器和客户端，我已经设法与服务器和客户端进行通信。但是我的问题是，在golang中读取的TCP是非阻塞的。我想知道的是，golang中的读取是否有可能像C中的读取一样被阻塞。谢谢 编辑： 这是服务器的源代码： 和我的客户： 问题答案： 可以返回部分数据。从该文档，“如果某些数据是可用的，但不是LEN（P）个字节，读取常规返回什么是可用的，而不是等待更多。” 无论
-
本文向大家介绍nodejs读取并去重excel文件，包括了nodejs读取并去重excel文件的使用技巧和注意事项，需要的朋友参考一下 如何使用，直接上代码 解析一下 node-xlsx导出的数据结构如下： 以上就是小编整理的全部内容，很多时候我们用到对EXCEL的文件操作，大家在测试的时候如还有任何疑问可以在下面的留言区讨论，感谢大家对呐喊教程的支持。
-
我有一个使用SimpleJDBCCall调用DB过程的DAO函数。但是，我无法读取存储过程返回的CLOB数据。当我尝试对返回的CLOB值（result.get（“out_rtn_xml”））执行.toString（）时，我只在字符串中得到以下内容:oracle.sql.CLOB@f762282a 下面是代码片段。
-
我有一个数据框，行名称中有单元格ID，列x中有分类。 我还有一个矩阵，列中有细胞ID，行中有基因。 我想粘贴来自数据框的矩阵分类的名称，请参见下面的示例。
-
问题内容： 我在通过此测试时遇到问题。问题是，我的结构体中的方法需要写入属性，但接口不接受指针作为其接收者。 测试输出： 正如我提到的，不会被写入，因为我无法将函数接收器设置为指针，因为它不能满足。 问题答案： 如果继续使用一个 指针 来，它应该工作： 然后： 我错过了： 您需要调用指针接收器，而不是值接收器。 由于所有内容都是通过Go中的值传递的，因此使用值接收器将 复制 该实例。