关于nifiExecuteScriptprocessorpython和groovy语言实现和noalternativesforpython的问题就给大家分享到这里，感谢你花时间阅读本站内容，更多关于a

关于nifi ExecuteScript processor python 和 groovy 语言实现和no alternatives for python的问题就给大家分享到这里，感谢你花时间阅读本站内容，更多关于android studio 出现 Error:Execution failed for task '':app:processDebugResources''. > 的问题、AndroidStudio3.0 Error:Execution failed for task '':app:processDebugResources''.、Android编译程序出现Execution failed for task '':app:processDebugResources''.、Chrome Android 上 createScriptProcessor 的奇怪行为等相关知识的信息别忘了在本站进行查找喔。

• nifi ExecuteScript processor python 和 groovy 语言实现（no alternatives for python）
• android studio 出现 Error:Execution failed for task '':app:processDebugResources''. > 的问题
• AndroidStudio3.0 Error:Execution failed for task '':app:processDebugResources''.
• Android编译程序出现Execution failed for task '':app:processDebugResources''.
• Chrome Android 上 createScriptProcessor 的奇怪行为

nifi ExecuteScript processor python 和 groovy 语言实现（no alternatives for python）

研究了几天 nifi 的 ExecuteScript processor，在同事的帮助下终于调试通过了，记录 python 和 groovy 语言的不同实现：

python：

import json
import java.io
from org.apache.commons.io import IOUtils
from java.nio.charset import StandardCharsets
from org.apache.nifi.processor.io import StreamCallback
from org.apache.nifi.processors.script import ExecuteScript


class PyStreamCallback(StreamCallback):
    def __init__(self):
        pass

    def process(self, inputStream, outputStream):
        text = IOUtils.toString(inputStream, StandardCharsets.UTF_8)
        obj=json.load(text)
        newObj = {
            "Source": "NiFi",
            "ID": "python",
            "Name": "test"
            "meta_data": obj[''meta'']
        }
        outputStream.write(bytearray(json.dumps(newObj, indent=4).encode(''utf-8'')))


flowFile = session.get()
if flowFile != None:
    flowFile = session.write(flowFile, PyStreamCallback())
    session.transfer(flowFile, ExecuteScript.REL_SUCCESS)
else:
    pass

groovy：

import org.apache.commons.io.IOUtils
import java.nio.charset.*

def flowFile = session.get();

def slurper = new groovy.json.JsonSlurper()
if (flowFile == null) {
    return;
}
def flag=false
flowFile = session.write(flowFile,
    { inputStream, outputStream ->
            def text = IOUtils.toString(inputStream,StandardCharsets.UTF_8)    
            def obj = slurper.parseText(text)
            flag=false
            def bbdErrorLog= obj.bbd_error_log
            def bbdErrorLogs=bbdErrorLog.split("code\":")
            if(bbdErrorLogs.size()==2){
                if (bbdErrorLog.startsWith("[{\"message")){
                    errorLogCode=Integer.parseInt(bbdErrorLogs[1].split("}")[0])
                }else{
                    errorLogCode=Integer.parseInt(bbdErrorLogs[1].split(",")[0])
                }                
                if (errorLogCode==2000002){
                    pattern= ~"吊销 | 注销"
                    def enterprise_status=obj.enterprise_status
                    def company_type=obj.company_type
                    if (company_type=="农民专业合作社"||company_type=="集体所有制"||company_type=="股份合作制"){
                        flag=true
                    }else if(enterprise_status=~pattern){ 
                        flag=true
                    }
                }else if (errorLogCode==2000302){
                    flag=true
                }else if (errorLogCode==1000202){
                    pattern= ~"吊销 | 注销"
                    def enterprise_status=obj.enterprise_status
                    if(enterprise_status=~pattern){ 
                        flag=true
                    }
                }else if (errorLogCode==1001402){
                    pattern= ~/[\u4e00-\u9fa5]/
                    def regOrg=obj.regorg
                    if(regOrg==~pattern&&regOrg.length()<20){
                        flag=true
                    }
                }
            }else{
                errorLogList=[1000101,1000401,1000501,1000601,1001201,1001301,1001401,2000002]                
                isFind=true
                for (field in bbdErrorLogs){
                    if (field=="[{\""||field.startsWith("[{\"message\"")){
                        continue
                    }
                    int num = Integer.parseInt(field.substring(0,7))
                    if (errorLogList.find{it == num}==null){
                        isFind=false
                    }
                }
                if (isFind){
                    pattern= ~"吊销 | 注销"
                    def enterprise_status=obj.enterprise_status
                    if(enterprise_status=~pattern){ 
                        flag=true
                    }
                }
                
            }
            def builder = new groovy.json.JsonBuilder()
            builder.call(obj)
            outputStream.write(builder.toPrettyString().getBytes(StandardCharsets.UTF_8)) 
    } as StreamCallback)

    if(flag){
        flowFile = session.putAttribute(flowFile, "etl_flag", "DATA_MATCHED")
    }else{
        flowFile = session.putAttribute(flowFile, "etl_flag", "DATA_NOT_MATCH")
    }

session.transfer(flowFile, ExecuteScript.REL_SUCCESS)

android studio 出现 Error:Execution failed for task '':app:processDebugResources''. > 的问题

打开命令窗口 cd 到当前项目路径
window 运行 gradlew assembleDebug --info
linux 运行 ./gradlew assembleDebug --info
查看 error，一般就知道缺少哪个素材了

修改回答

AndroidStudio3.0 Error:Execution failed for task '':app:processDebugResources''.

android studio 

Information:Gradle tasks [:app:assembleDebug]

app\build\intermediates\manifests\full\debug\AndroidManifest.xml

Error:(27) error: unknown element <category> found.
Error:(27) unknown element <category> found.
Error:java.util.concurrent.ExecutionException: java.util.concurrent.ExecutionException: com.android.tools.aapt2.Aapt2Exception: AAPT2 error: check logs for details
Error:java.util.concurrent.ExecutionException: com.android.tools.aapt2.Aapt2Exception: AAPT2 error: check logs for details
Error:com.android.tools.aapt2.Aapt2Exception: AAPT2 error: check logs for details
Error:Execution failed for task '':app:processDebugResources''.
> Failed to execute aapt
Information:BUILD FAILED in 10s
Information:6 errors
Information:0 warnings

Information:See complete output in console

解决方法 ：

add this code in gradle.properties in the root project:

org.gradle.jvmargs=-Xmx1536m
android.enableAapt2=false

Android编译程序出现Execution failed for task '':app:processDebugResources''.

Android编译程序出现org.gradle.api.tasks.TaskExecutionException: Execution failed for task '':app:processDebugResources''.错误

如何处理
打开AndroidStudio的terminal，在命令行输入命令：gradlew compileDebugSource --stacktrace -info或gradlew assembleDebug --info

Chrome Android 上 createScriptProcessor 的奇怪行为

<body>
    <textarea id=field cols=32 rows=4></textarea>
    <br>
    Buffer size <input id=buf_size value=4096>
    <br>
    <input type=button value=Start onclick="test_start()">
</body>
<script>
var audCtx;
var recorder;
var start_time;
var buffer_counter = 0;


function test_start()
{
    audCtx = new (window.AudioContext || window.webkitaudiocontext)();
    navigator.getUserMedia = navigator.getUserMedia || navigator.webkitGetUserMedia || navigator.mozGetUserMedia || navigator.msGetUserMedia;
    navigator.getUserMedia({audio: true,video: false},function(s){rec_init(s)},function(e){console.log("Media init error: " + e);});
    setInterval("stat()",500);
}


function stat()
{
    if (recorder)
    {
        var curr_time = new Date().getTime() - start_time;
        var str = "Declared freq:\t" + recorder.context.sampleRate + ''\n'';
        str += "Measured freq:\t" + parseInt(1000 * (buffer_counter * buf_size.value / curr_time)) + ''\n'';
        str += "Buffer counter:\t" + buffer_counter + ''\n'';
        str += "Measure time:\t" + (curr_time / 1000);
        field.value = str;
    }
}


function rec_init(s)
{
    src = audCtx.createmediastreamsource(s); 
    recorder = audCtx.createscriptprocessor(buf_size.value,1,1);
    start_time = new Date().getTime();

    recorder.onaudioprocess = function(d)
    {
        buffer_counter++;
    }

    src.connect(recorder);

    recorder.connect(audCtx.destination);
}
</script>