c# - Querying the write model for duplicated aggregate root property -

-

I am implementing the CursS pattern with Event Outsourcing, I connect between NSWers, NewventStore and NES (NSB and AvestStore) I am using). .

My application will regularly check a web service to download and process any file. When a file is received, a command (download file) is sent to the bus, and the file is received by the commandhandler, which creates a new parallel root file and handles the message.

file total route now) I must check that the content of the file does not match any other file content (since the web service guarantee that only the name of the file is unique, and the content Can be duplicated with different names), comparing it and comparing it to the list of hashed content.

The question is, do I have to save the list of hash codes? Is it allowed to check the model of reading it? Public class file: Kulbase {public file (downloadable file CMD, IFile service file download service, IKlamicRealizer service service provider, IBIS bus): It () {// Download the content of the code file Deserialize it, publish it and publish an event. }} Public Category FileCommandHandler: IHandleMessages & lt; DownloadFile & gt ;, IHandleMessages & lt; ExtractFile & gt; {Public void handle} (For example, is it possible to do this? (Honestly, I do not think it is so, because the reading model should always be stale!) Var file = readModelContext.GetFileByHashCode (hash (Command.FileContent); If (file! = Null) throw a new exception ("file content matches file already downloaded"); // Since there is no way to query an event source such as file content: // eventSourceRepository.Find & lt; File & gt; (C = & gt; c.HashCode == hash (command.FileContent)); }}

It depends on a lot of things ... being one of them Due to input But whenever you are facing this problem in a "bridge-based" fashion (you are asking for a survey for work (downloading and analyzing a file), without worrying about the collision This whole process can create serials. Now he can not give the desired rate at which you want to handle "work", but more importantly ... have you measured? Let's assume that the serial is not going to work for a minute and assume that. What are we talking about? Some 100, 1000, ... millions? Depending on that hash, you can fit in the memory and if / when the process goes down, then it can be made again. The opportunity to split your problem on the axis of time or context can also be the beginning of the morning or just today, or maybe every file since the file files of this month? In fact, I think you should go deeper in the place of your problem. In addition, this event feels like a strange problem to use sourcing, but YMMV.

Comments

Post a Comment

Popular posts from this blog

Pass DB Connection parameters to a Kettle a.k.a PDI table Input step dynamically from Excel -

-
Image
I have a requirement whenever I run my own kettle, dynamically took database connection parameters from an excel source Every run should go. I have an Excel column names: hostname, username, database, password. I want to pass these connection parameters to my table input stage dynamically whenever it runs the job. This is what I was trying to do. You can get it Connection parameters from the DB reading source (for example Excel or a CSV file in my example) < / Li> Store the parameters in the variable Using the variable in your connection's settings. Setting Variables Create another conversion for (you can not do it in the same conversion Uses): set variables element variable: The element that reads / writes your data creates a new connection and sets the connection parameter using $ {variable name_} Note that you will need to type in the field field in the field $ {password} Also keep in mind that this can be a security problem as the
Read more

multithreading - PhantomJS-Node in a for Loop -

-
I am trying to implement a screen-scraps application that opens a URL in which a parameter changes as it is for a loop: var data = [ '100', '101', '102', '103', '104']; (Var indexA = 0; indexA & lt; data.length; indexA ++) for {Phantom Generation ({'port': freeport}, function (pH) {ph.create page (function (page) {page.open ("http: //...++ data [index B] +" ... " , Status {console.log ("open site:" + data [index B], position); / * OLD * / indexB ++; page evaluation (function () {// page scrape and an object Return}, function {console.log (result.dataRequest); // here is the problem}); / * new and fixed * / indexB ++} first console Logs it: Open Site: 100 Success Opens Site: 101 Success B Ola Site: 102 Success Opening Site: 103 Success Opened Site: 104 Success Which is good. Data is verified in scrap HTML and from index to array Matches. So in page 101 I scrap '101 and retrieve' and pu
Read more

c++ - MATLAB .m file to .mex file using Matlab Compiler -

-
I know that it can speak as a very famous topic, but something that helps me with it Not found This scenario is: I have my functions function, no matter what's inside, it's a generic function that may depend on other toolboxes. Does. Has input and output; I want to generate the same myFun.mex function; : Lib myFun This way I get some new files: libmyfun.c libmyfun.dll Libmyfun.exp libmyfun.exports libmyfun .h libmyfun.lib Reading around and I think that Creating a myfun.cpp that is very famous is included: / * gateway function * / zero max function (ent NLHS, MXARRA * PLS [], int NRHS, CONST M Xeray * PHS []) Here is the Variable Deals * / / * code here * /} I have tried to do this and are called Regular of Max Generation: Max ('- v', 'myfun.cpp') But I get many errors, and I should say that my myfun.cpp copy / Paste Function is where I have a lot of doubts ... especially on input / output management. My q
Read more