如何使用Stream Analytics作业再次处理Azure事件中心中的事件？

问题描述

我已经建立了一个事件中心，用于存储一些事件以及一个Azure Stream Analytics作业，该作业将处理这些事件并将其输出到Blob容器中。假设中心中的邮件保留时间设置为5天，我该如何再次处理这些事件，即将其输出到数据库中？

解决方法

好的，对于一个简单的场景，您只需将 2020-09-05 12:05:06.844 20472-20472/com.davidigbogree.recapp E/RecorderActivity: sdcard access error 2020-09-05 12:05:07.813 20472-20572/com.davidigbogree.recapp W/ConnectionTracker: Exception thrown while unbinding java.lang.IllegalArgumentException: Service not registered: lz@b7656b7 at android.app.LoadedApk.forgetServiceDispatcher(LoadedApk.java:1494) at android.app.ContextImpl.unbindService(ContextImpl.java:1639) at android.content.ContextWrapper.unbindService(ContextWrapper.java:703) at ci.b(:com.google.android.gms.dynamite_measurementdynamite@203019046@20.30.19 (040306-0):1) at ci.a(:com.google.android.gms.dynamite_measurementdynamite@203019046@20.30.19 (040306-0):6) at ma.A(:com.google.android.gms.dynamite_measurementdynamite@203019046@20.30.19 (040306-0):10) at ll.a(:com.google.android.gms.dynamite_measurementdynamite@203019046@20.30.19 (040306-0):3) at ec.run(:com.google.android.gms.dynamite_measurementdynamite@203019046@20.30.19 (040306-0):3) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:457) at java.util.concurrent.FutureTask.run(FutureTask.java:266) at jg.run(:com.google.android.gms.dynamite_measurementdynamite@203019046@20.30.19 (040306-0):6) 2020-09-05 12:05:09.566 20472-20472/com.davidigbogree.recapp D/AndroidRuntime: Shutting down VM --------- beginning of crash 2020-09-05 12:05:09.571 20472-20472/com.davidigbogree.recapp E/AndroidRuntime: FATAL EXCEPTION: main Process: com.davidigbogree.recapp,PID: 20472 java.lang.IllegalStateException: Could not execute method for android:onClick at androidx.appcompat.app.AppCompatViewInflater$DeclaredOnClickListener.onClick(AppCompatViewInflater.java:414) at android.view.View.performClick(View.java:6748) at android.view.View$PerformClick.run(View.java:25458) at android.os.Handler.handleCallback(Handler.java:790) at android.os.Handler.dispatchMessage(Handler.java:99) at android.os.Looper.loop(Looper.java:164) at android.app.ActivityThread.main(ActivityThread.java:6549) at java.lang.reflect.Method.invoke(Native Method) at com.android.internal.os.RuntimeInit$MethodAndArgsCaller.run(RuntimeInit.java:438) at com.android.internal.os.ZygoteInit.main(ZygoteInit.java:888) Caused by: java.lang.reflect.InvocationTargetException at java.lang.reflect.Method.invoke(Native Method) at androidx.appcompat.app.AppCompatViewInflater$DeclaredOnClickListener.onClick(AppCompatViewInflater.java:409) at android.view.View.performClick(View.java:6748) at android.view.View$PerformClick.run(View.java:25458) at android.os.Handler.handleCallback(Handler.java:790) at android.os.Handler.dispatchMessage(Handler.java:99) at android.os.Looper.loop(Looper.java:164) at android.app.ActivityThread.main(ActivityThread.java:6549) at java.lang.reflect.Method.invoke(Native Method) at com.android.internal.os.RuntimeInit$MethodAndArgsCaller.run(RuntimeInit.java:438) at com.android.internal.os.ZygoteInit.main(ZygoteInit.java:888) Caused by: java.lang.NullPointerException: Attempt to invoke virtual method 'void android.media.MediaRecorder.stop()' on a null object reference at com.davidigbogree.recapp.RecorderActivity.stopRecording(RecorderActivity.java:94) at java.lang.reflect.Method.invoke(Native Method) at androidx.appcompat.app.AppCompatViewInflater$DeclaredOnClickListener.onClick(AppCompatViewInflater.java:409) at android.view.View.performClick(View.java:6748) at android.view.View$PerformClick.run(View.java:25458) at android.os.Handler.handleCallback(Handler.java:790) at android.os.Handler.dispatchMessage(Handler.java:99) at android.os.Looper.loop(Looper.java:164) at android.app.ActivityThread.main(ActivityThread.java:6549) at java.lang.reflect.Method.invoke(Native Method) at com.android.internal.os.RuntimeInit$MethodAndArgsCaller.run(RuntimeInit.java:438) at com.android.internal.os.ZygoteInit.main(ZygoteInit.java:888) 设置为更早的时间，如：

job output start time