问题标签 [sink]

我正在使用 Serilog Sink Serilog.Sinks.Email。我收到电子邮件。不幸的是，还有“信息”。如果是警告错误或致命错误，我想先接收电子邮件。

有没有办法设置这个？“信息”不应再通过电子邮件发送。但信息应重新写入 .txt 文件。如果它是警告、错误或致命的，我愿意接收电子邮件。

我有这个代码：

我的目标是在 for 循环中填充一个 .txt 文件。但是，当我看到输出文件dframe.txt时，它看起来像：

然而，当我手动运行时，我可以看到预期的输出被写入了 5 次：

我该如何解决这个问题？我正在使用append=TRUE，但显然还不够。

我有一个源代码，想将结果输出到一个 txt 文件。我设法使用 sink() 函数来做到这一点，如下所示：

除了一个细节外，一切都很好。在我的函数输出中，有一些矩阵往往很大。当我将结果显示在控制台上时，矩阵往往会根据屏幕上的空间打破，这是很正常的（如果我有更大的空间，通过将帮助/图表推到最右边，更多的列会出现在矩阵被破坏之前）。我的问题是，完全相同的事情发生在SinktestA.txt，基本上，它反映了控制台中的预期（我尝试了不同的导出并在控制台中提供越来越少的空间，并且输出文件中的结果破坏了矩阵列数更小或更大）。

例如，由于矩阵没有并排拟合所有列，因此它在输出中的显示方式如下：

注意：我实际上有更多列，但例如，考虑到我在控制台上的空间只显示 4 列，之后必须打破矩阵。

我的问题是，有没有一种方法或参数可以用来指示在输出中的矩阵被破坏之前要使用的字符数或其他东西？或者一种指示输出的方法应该反映输出结果但不完全是它的格式？

抱歉，如果在任何时候都不清楚。

我试图将我自己的 Spring Cloud 数据流自定义接收器部署到 Cloud Foundry 上。

我的依赖如下：

我在部署此应用程序时看到的只是创建了错误通道订阅者，但没有创建输入订阅者。因此，此应用程序不会收到任何消息。此应用程序的源是带有休息控制器的自定义源。默认开箱即用的流媒体应用程序——LogSink 成功运行。但是我需要创建一个customsink来在上面构建东西。有人看到我在这里缺少的问题吗？

我正在尝试设计即时消息传递，或者更准确地说，我正在做基于回合制的游戏，其机制如下：

玩家“A”做某事并将有关他的步数的信息发送给玩家“B”。玩家“B”收到此信息，也正在做某事并回复玩家“A”。

我正在考虑卡夫卡接收器连接器是否可以作为客户端托管在卡夫卡之外？因为这是避免编写大量代码并通过分区、模式等向客户端提供消息接收器的良好机制的好方法，所以我想做以下事情，例如：

两个客户端可以订阅一个主题，并且可以在彼此之间交换带有一些信息的消息。

有可能是这样的吗？

或者，如果不可能，我只是在想.. 如果做 2 个侦听器，一个在源连接器中，另一个在接收器中，用于以 kafka 管理的任何方式发送和接收消息。有没有道理，你怎么看？

我只是在收集想法，如何以良好的性能、可扩展性和更少的工作量尽可能快地实现它。:)

我想在contiki. 我有两种类型的事物，每个事物网络都有一个接收器节点，该节点将数据发送到其接收器。接收器应与自身通信。根据该Support of multiple sinks via a virtual root for the RPL routing protocol. EURASIP Journal on Wireless Communications and Networking 2014 2014:91论文，接收器可以通过多种方式进行通信。例如将数据包转发到正确的接收器，将数据包转发到所有接收器和将数据包转发到中央单元。本文重点介绍第三种方法。但不要在contiki. 是否有实现接收器之间通信的示例contiki？

我通常为每个项目使用一个 script.R 文件（每个项目持续几周）。我想设置一个流程，这样每天当我打开 RStudio 时，我都可以启动一个文件，将我在控制台中看到的所有内容（输入、输出、警告）存储到一个文件中。我还希望它每天都创建一个新文件。我在这里阅读了一些关于如何做部分内容的讨论，但我不够聪明，无法自己将它们整合在一起。这是我到目前为止所拥有的：

我认为这完成了什么：如果这是我第一次这样做，我会得到一个日志文件，它会在一个新文件中捕获所有输出，但如果我在 AM 中做一些工作，它将添加到现有文件中，全部关闭出去，并在当天晚些时候重新开始。

这没有完成：它不捕获输入或警告消息，而且我认为它有点笨拙。

我是否正确，这完成了我认为的事情？有没有办法修改这个（或做类似的事情），让我也可以捕获输入和警告（基本上是控制台中看到的其余内容）？

谢谢！

我试图将三个数据框（从数据库中填充）放在一个 csv 文件中，所以我使用了 sink()。

这导致代码显示在底部

我怎样才能删除这个？

是否有任何简单的方法，当在 R 中使用 sink() 写入 csv 文件时，写入前 2 个单元格为空白且第三个单元格具有特定字符串的行？这并不是那么简单，我正在为此苦苦挣扎。我尝试了以下方法：

为了验证，我在上面的示例中所需的输出将是一个 CSV 文件，其中每个数字 1、2、3、4、5 在它们自己的行中，每个在 C 列中。对此的任何帮助表示赞赏！

我在一个项目中使用 spark 2.2 struct streaming 将 kafka msg 读入 oracle 数据库。进入 kafka 的消息流约为每秒 4000-6000 条消息。

当使用 hdfs 文件系统作为接收器目标时，它工作正常。当使用 foreach jdbc writer 时，随着时间的推移会有很大的延迟。我认为滞后是由 foreach 循环引起的。

jdbc sink 类（独立类文件）：

水槽部分：

如果我改变最后一行

.writeStream.format("csv")...

进入 jdbc foreach 接收器，如下所示：

滞后出现。

我猜这个问题很可能是由 foreach 循环机制引起的——它不是在批处理模式下处理的，就像一个批处理中的几千行一样，作为一个 oracle DBA，我已经微调了 oracle 数据库端，主要是数据库正在等待空闲事件。已经尝试通过设置来避免过度提交connection.setAutoCommit(false)，任何建议都将不胜感激。