小编And*_*ndy的帖子

我经常忘记哪个是Camel案例,哪个是Pascal案例.所以我想也许有点历史会有所帮助.这些公约的名称来自哪里？他们的名字背后有一些历史吗？

我只是想知道迷你NiFi MiNiFi与NiFi有何不同？

我们还有其他功能吗？为什么需要引入它？

任何想法或链接都会有很大的帮助.

我很抱歉,如果这已经得到解答,但我一直在使用的搜索术语(即JAXB @XmlAttribute压缩或JAXB XML编组到String不同的结果)没有提出任何建议.

我正在使用JAXB来取消/编组带注释@XmlElement和@XmlAttribute注释的对象.我有一个格式化程序类,它提供了两个方法 - 一个包装marshal方法并接受对象编组和一个OutputStream,另一个只接受对象并将XML输出作为String返回.不幸的是,这些方法不能为相同的对象提供相同的输出.封送到文件时,内部标记的简单对象字段@XmlAttribute将打印为:

<element value="VALUE"></element>

当编组到一个字符串时,它们是:

<element value="VALUE"/>

我更喜欢这两种情况的第二种格式,但我很好奇如何控制差异,并且无论如何都会满足于它们.我甚至创建了一个静态编组器,两种方法都使用它来消除不同的实例值.格式代码如下:

/** Marker interface for classes which are listed in jaxb.index */
public interface Marshalable {}

/** Local exception class */
public class XMLMarshalException extends BaseException {}

/** Class which un/marshals objects to XML */
public class XmlFormatter {
    private static Marshaller marshaller = null;
    private static Unmarshaller unmarshaller = null;

    static {
        try {
            JAXBContext context …

来自的输出$NIFI_HOME/logs/nifi-app.log：

2016-10-26 12:45:13,304 ERROR [Timer-Driven Process Thread-6] o.apache.nifi.processors.standard.PutSQL
org.apache.nifi.processor.exception.ProcessException: org.apache.commons.dbcp.SQLNestedException: Cannot create JDBC driver of class 'com.mysql.jdbc.Driver' for connect URL 'jdbc:sqlserver://*BLOCKED*/*BLOCKED*'
        at org.apache.nifi.dbcp.DBCPConnectionPool.getConnection(DBCPConnectionPool.java:234) ~[na:na]
        at sun.reflect.GeneratedMethodAccessor393.invoke(Unknown Source) ~[na:na]
        at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[na:1.8.0_101]
        at java.lang.reflect.Method.invoke(Method.java:498) ~[na:1.8.0_101]
        at org.apache.nifi.controller.service.StandardControllerServiceProvider$1.invoke(StandardControllerServiceProvider.java:177) ~[nifi-framework-core-1.0.0.jar:1.0.0]
        at com.sun.proxy.$Proxy81.getConnection(Unknown Source) ~[na:na]
        at org.apache.nifi.processors.standard.PutSQL.onTrigger(PutSQL.java:218) ~[na:na]
        at org.apache.nifi.processor.AbstractProcessor.onTrigger(AbstractProcessor.java:27) ~[nifi-api-1.0.0.jar:1.0.0]
        at org.apache.nifi.controller.StandardProcessorNode.onTrigger(StandardProcessorNode.java:1064) ~[nifi-framework-core-1.0.0.jar:1.0.0]
        at org.apache.nifi.controller.tasks.ContinuallyRunProcessorTask.call(ContinuallyRunProcessorTask.java:136) [nifi-framework-core-1.0.0.jar:1.0.0]
        at org.apache.nifi.controller.tasks.ContinuallyRunProcessorTask.call(ContinuallyRunProcessorTask.java:47) [nifi-framework-core-1.0.0.jar:1.0.0]
        at org.apache.nifi.controller.scheduling.TimerDrivenSchedulingAgent$1.run(TimerDrivenSchedulingAgent.java:132) [nifi-framework-core-1.0.0.jar:1.0.0]
        at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [na:1.8.0_101]
        at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308) [na:1.8.0_101]
        at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180) [na:1.8.0_101]
        at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294) [na:1.8.0_101]
        at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) [na:1.8.0_101]
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) [na:1.8.0_101]
        at …

是否可以在NIFI处理器中使用xmlHttpRequest来调用远程休息服务？在我的情况下,ExecuteScript处理器(使用Javascript)无法评估XMLHttpRequest; 我可以使用任何类似的解决方案来获取响应数据吗？

var OutputStreamCallback = Java.type("org.apache.nifi.processor.io.OutputStreamCallback");
var StandardCharsets = Java.type("java.nio.charset.StandardCharsets");

Date.prototype.isValid = function () {
    return (Object.prototype.toString.call(this) === "[object Date]")
        && !isNaN(this.getTime());
};

var flowFile = session.get();

if (flowFile != null) {
    var fromDate = flowFile.getAttribute('fromDate')
    var uid = flowFile.getAttribute('uid')

    var xmlhttp = null;
    var result = null;

        xmlhttp = new XMLHttpRequest();
        if (typeof xmlhttp.overrideMimeType != 'undefined') {
            xmlhttp.overrideMimeType('application/json');

    } else if (window.ActiveXObject) {
        xmlhttp = new ActiveXObject("Microsoft.XMLHTTP");
    }
    xmlhttp.open('GET', "similar url here WorkInfo?dateFrom=?&uid=?", true);
    xmlhttp.send(dateFrom, …

我想在我的CentOS系统上运行Apache NiFi.我下载了它并使用命令运行它:

/opt/nifi-1.1.1.0-12/bin/nifi.sh start

结果在这里:

Java home: /usr/java/jdk1.7.0_45
NiFi home: /opt/nifi-1.1.1.0-12

Bootstrap Config File: /opt/nifi-1.1.1.0-12/conf/bootstrap.conf

2016-03-06 22:02:08,477 INFO [main] org.apache.nifi.bootstrap.Command Starting Apache NiFi...
2016-03-06 22:02:08,478 INFO [main] org.apache.nifi.bootstrap.Command Working Directory: /opt/nifi-1.1.1.0-12
2016-03-06 22:02:08,478 INFO [main] org.apache.nifi.bootstrap.Command Command: /usr/java/jdk1.7.0_45/bin/java -classpath /opt/nifi-1.1.1.0-12/./conf:/opt/nifi-1.1.1.0-12/./lib/jcl-over-slf4j-1.7.12.jar:/opt/nifi-1.1.1.0-12/./lib/log4j-over-slf4j-1.7.12.jar:/opt/nifi-1.1.1.0-12/./lib/nifi-runtime-1.1.1.0-12.jar:/opt/nifi-1.1.1.0-12/./lib/logback-classic-1.1.3.jar:/opt/nifi-1.1.1.0-12/./lib/nifi-nar-utils-1.1.1.0-12.jar:/opt/nifi-1.1.1.0-12/./lib/nifi-properties-1.1.1.0-12.jar:/opt/nifi-1.1.1.0-12/./lib/slf4j-api-1.7.12.jar:/opt/nifi-1.1.1.0-12/./lib/logback-core-1.1.3.jar:/opt/nifi-1.1.1.0-12/./lib/nifi-documentation-1.1.1.0-12.jar:/opt/nifi-1.1.1.0-12/./lib/nifi-api-1.1.1.0-12.jar:/opt/nifi-1.1.1.0-12/./lib/jul-to-slf4j-1.7.12.jar -Djava.net.preferIPv4Stack=true -Dsun.net.http.allowRestrictedHeaders=true -Djava.protocol.handler.pkgs=sun.net.www.protocol -Dorg.apache.jasper.compiler.disablejsr199=true -Xmx512m -Djava.awt.headless=true -Xms512m -Dnifi.properties.file.path=/opt/nifi-1.1.1.0-12/./conf/nifi.properties -Dnifi.bootstrap.listen.port=32864 -Dapp=NiFi org.apache.nifi.NiFi 

然后我用命令检查Apache NiFi的状态:

/opt/nifi-1.1.1.0-12/bin/nifi.sh status

结果是:

Java home: /usr/java/jdk1.7.0_45
NiFi home: /opt/nifi-1.1.1.0-12

Bootstrap Config File: /opt/nifi-1.1.1.0-12/conf/bootstrap.conf

2016-03-06 22:03:21,227 INFO [main] org.apache.nifi.bootstrap.Command Apache NiFi is currently running, listening to Bootstrap on …

我有以下插入语句：

1. insert into temp1 values (test1, test2)

2. insert into temp2 values (test3)

预期成绩：

1. insert into temp1 values (100, 200)

2. insert into temp2 values (300)

从本质上讲，我想更换一次查询的文字test1，test2与价值100，200分别和第二个查询替换test3与价值300。有人可以为上述用例提供映射文件帮助吗？

我尝试了以下操作，但没有任何效果。

搜索值（RegEx）替换值

(1)(.*values.*)(.*test1)(.*,)(.*test2) -> $2 val1 $4 val2

(2)(.*values.*)(.*test1) -> $2 val3