问题标签 [sink]

For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.

0 投票
2 回答
1692 浏览

r - RStudio / R:sink()在哪里保存我的文件

我在 RStudio 中运行分析并使用 sink 将输出存储在文件中,因为行数太大而无法从控制台手动复制它。代码是:

现在,我在哪里可以找到我机器上的 filename.txt 文件?

谢谢

0 投票
1 回答
3282 浏览

sql-server - Serilog 可配置 SQL Server 接收器

我正在尝试使用可在web.config.

有没有办法以例如滚动文件接收器的方式做到这一点?

例子:

我已经下载了MSSQLserilog 的扩展,它可以在 (C#) 之类的代码中运行:

但不喜欢:

当然有可能解决这个问题,但我仍然想知道这是否可能,出于好奇心和更好看的代码。

有没有人让它工作?

感谢回复

0 投票
1 回答
193 浏览

r - 将每次运行 for 循环的控制台输出保存在单独的文件中

我想将每次运行 for 循环的控制台输出保存在单独的文本文件中。我正在做以下事情。

但是一段时间后我收到了一个错误

最有效的方法是什么?

0 投票
1 回答
629 浏览

r - r cat 命令生成输出,其中 /t 解释为 /t 而不是制表符

我想使用以下命令生成类似“我想测试\ttab”的输出,但输出是“我想测试选项卡”。我希望 \t 在那里而不是被解释为制表符分隔符。有没有办法做到这一点?任何人都可以帮忙吗?非常感谢您!

谢谢,R

0 投票
1 回答
387 浏览

hdfs - 水槽事件被截​​断

这里我遇到一个问题,我从Kafka源接收消息,并编写一个拦截器从kafka消息(json格式)中提取两个字段(dataSoure和businessType)。这里我使用 gson.fromJson()。但问题是我得到了以下错误。

这里我想知道Flume是否会在超过限制时截断Flume事件?如果是,如何将其设置为更大的值。因为我的 kafka 消息总是很长,大约 60K 字节。

期待回复。提前致谢!

2015-12-09 11:48:05,665 (PollableSourceRunner-KafkaSource-apply) [错误 - org.apache.flume.source.kafka.KafkaSource.process(KafkaSource.java:153)] KafkaSource 异常,{} com.google。 gson.JsonSyntaxException: com.google.gson.stream.MalformedJsonException: com.google.gson.Gson.fromJson(Gson.java:809) com.google.gson.Gson.fromJson(Gson) 的第 1 行第 4096 列未终止的字符串.java:761) 在 com.xxx.flume.interceptor.JsonLogTypeInterceptor.intercept(JsonLogTypeInterceptor.java:43) 在 com.xxx.flume.interceptor 的 com.google.gson.Gson.fromJson(Gson.java:710)。 JsonLogTypeInterceptor.intercept(JsonLogTypeInterceptor.java:61) 在 org.apache.flume.interceptor.InterceptorChain.intercept(InterceptorChain.java:62) 在 org.apache.flume.channel.ChannelProcessor。org.apache.flume.source.kafka.KafkaSource.process(KafkaSource.java:130) 上的 processEventBatch(ChannelProcessor.java:146)

0 投票
1 回答
1332 浏览

r - 运行 R 脚本时创建警告日志文件

我想为 R 脚本创建警告/错误日志。
请看下面的例子:

我期待它会列出所有警告:
警告消息:
1:在日志中(i - 50):产生了 NaN
2:在日志中(i - 50):产生了 NaN
3:在日志中(i - 50):产生了 NaN

但是对于 1:30 中的循环 i,all.rout 文件中只有一行:
有 30 个警告(使用 warnings() 来查看它们)

知道如何解决吗?

我创建了基于另一个主题的代码:

在命令行下运行 R 脚本时输出错误/警告日志(txt 文件)

0 投票
2 回答
4409 浏览

r - 保存 r 脚本的输出,包括其命令

我想将我的 r 脚本输出的一部分(包括命令)保存到文本文件中。我知道 sink(),但它不包含命令,或者我找不到执行此操作的特定选项。

是否有可能r 会话中捕获命令及其输出。简单地编写一个 Rmd 或在控制台中捕获输出不是目前的解决方案。

0 投票
2 回答
533 浏览

character - Flume:Kafka Sink 和控制角色

我正在尝试使用 Flume 1.6 读取我的源文件(管道分隔的文本文件)并将它们提供给 kafka。

所有管道似乎都工作正常,所有记录都成功进入卡夫卡。但是,Flume 似乎在每个数据行的开头添加了 NUL 和 STX 控制字符。

这对我来说有点问题,因为最终我将所有数据从 Kafka 流式传输到 Amazon S3,最后进入 Amazon Redshift。由于这些控制字符,我将数据加载到 Redshift(COPY 命令)失败。

我花了相当多的时间在互联网上研究这个问题,但到目前为止还没有运气。我可以以某种方式指示 Flume 不要在我的源数据中添加这些字符吗?

我的 Flume 配置如下。我已经尝试过“exec”和“spoolDir”来源,但没有任何改变。

任何帮助表示赞赏。

谢谢普拉维什

0 投票
0 回答
987 浏览

r - 为什么使用接收器函数保存到文件返回空文件

我尝试使用 sink() 函数将屏幕文本保存到文件中。该文件已创建但其中没有任何数据。我做错了什么?这是我的玩具代码:

0 投票
2 回答
687 浏览

c++ - 将 g++ 编译错误消息从 TMB 库导出到文本文件

我正在尝试在 R 中使用 gcc (c++) 编译模型(使用 TMB 包)。错误如此之多,以至于在 Rstudio 中,我什至无法向上滚动查看它们的开头。因此,我想将控制台中的所有内容(消息、错误和警告)打印到文本文件中。这样我还可以比较不同的模型输出(或者特别是它们的失败)。

我尝试了以下事情:

=> 给我一个空文件(我或多或少预期)

=> 只打印最终错误

我忽略了什么?