akkadotnet/akka.net

Port of Akka actors for .NET

vicosoft4real

@vicosoft4real

this is lighthouse configuration: lighthouse{
actorsystem: "EduSaaSSystem" #POPULATE NAME OF YOUR ACTOR SYSTEM HERE
}

                akka {
                    actor { 
                        provider = "Akka.Cluster.ClusterActorRefProvider, Akka.Cluster"
                    }

                    remote {
                        log-remote-lifecycle-events = DEBUG
                        dot-netty.tcp {
                            transport-class = "Akka.Remote.Transport.DotNetty.TcpTransport, Akka.Remote"
                            applied-adapters = []
                            transport-protocol = tcp
                            #will be populated with a dynamic host-name at runtime if left uncommented
                            #public-hostname = "POPULATE STATIC IP HERE"
                            hostname = "0.0.0.0"
                            port = 4053
                        }
                    }            

                    loggers = ["Akka.Logger.NLog.NLogLogger,Akka.Logger.NLog"]

                    cluster {
                        #will inject this node as a self-seed node at run-time
                        seed-nodes = ["akka.tcp://EduSaaSSystem@127.0.0.1:4053"] #manually populate other seed nodes here, i.e. "akka.tcp://lighthouse@127.0.0.1:4053", "akka.tcp://lighthouse@127.0.0.1:4044"
                        roles = [lighthouse]
                    }
                }

Weston

@ronnyek

ok... more questions about streams

Weston

@ronnyek

I guess execution strategy, is the model always that you use materializer to materialize a graph, and that returns a ActorRef?

Seems like I've seen examples of runnablegraphs where I have no idea where the graph itself gets executed (they were just partial references)

the website scraper seems to materialize and store a ref to the actor on another actor, and feeds the graph input with .tell()

the twitter thingy seems to just kinda run it inline.. .no idea what the sttream from the twitter api looks like

Weston

@ronnyek

and per my question yesterday if I was looking ot build something like red node (I realize the materializer and graphdsl stuff still do things via fluent builders) would the components themselves just be graph stages where I might have a GraphStage<SourceShape<int>> for a source component

Bartosz Sypytkowski

@Horusiath

@ronnyek all execution is essentially done when a runnableGraph.Run(materializer) is called - this is the point when the graph it's actually constructed and started

also GraphStage is quite a low level API - it allow to build a custom logic using ideas of picking data from inputs and putting them in outputs

you may need it eventually, but it's not a must in most cases

Michal Dabrowski

@defrag2_twitter

Hey guys, i have some questions regarding handling and restoring of persistent actors.
Lets say i have 10k of persistent actors, P1...P1000. They are all under the supervision
of actor S. Now in other part of system, im retrieving some data from one of Px actors based on some inputs.
Is the best practice selecting them by selection or should supervisor S store somehow the map
of those child actors and reference them? Additionally when deploying new version of application and stopping all
of the P actors first, what are the best practices of bringing them back to life? All at once or
only if they are requested? If all at once i should store some data in order to recreate them. Cant find any resources on that. Thanks :)

Joshua Garnett

@joshgarnett

If you can, only load the persistent actors on demand, if only because that can put significant strain on your database loading a large number of persistent actors at once

Cluster Sharding abstracts a lot of what you are trying to do here

Michal Dabrowski

@defrag2_twitter

thanks, havent dig into cluster yet, probably will have to soon, so i'll dig

Andrew Young

@ayoung

if a node unexpectedly terminates on a cluster and another node spins up in its place on the same port, will the previous node still be considered unreachable?

i'm 85% sure that's a yes...

Joshua Garnett

@joshgarnett

I need to follow up on the akka.net impl, but each instance should have a unique id when it spins up

So even though its on the same host/port its considered a new node in the cluster

Andrew Young

@ayoung

right...

Weston

@ronnyek

@Horusiath well I want to effectively publish those components with metadata, ultimately allowing you to drag drop them and chain them together, save the layout and load later. Seems like the GraphStage lets you do exactly that... describe the shape of the component and its inputs and outputs and what to do on data in/out

Marc Piechura

@marcpiechura

@ronnyek you can do this with normal source / flows / sinks / graphs as well, they are all only blueprints until you call Run

var someChainedFlowActions = Flow.Create<Input>().Where().SelectAsync().....

At some point you can than do something like mySource.Where().Select( Input ).Via(someChainedFlowActions).RunWith(someSelectedSink, materializer)

GraphStages are useful if you want to implement something like Where, Select or custom sources/sinks for third party services, i.e. Azure, Kafka, files...

Anders Storhaug

@andersstorhaug

Anyone have success with cluster sharding on 1.3.1? Reincarnation isn't working for me, using SQLite and single seed node. Have checked configs several times, though I may try from scratch to make sure configs are correct

Aaron Stannard

@Aaronontheweb

@andersstorhaug it should all be working on 1.3.1

file an issue

with details if you think you've run into a bug

Anders Storhaug

@andersstorhaug

Ok, will try a few more things first

Thanks for the confirmation though. It may very well be a config issue on my side

Anders Storhaug

@andersstorhaug

Yep, with fresh sandbox project on 1.3.1 everything worked as expected

Arsene

@Tochemey

Hello I am getting the following exception and it is the first time:

MissingMethodException: Method not found: 'Void Hyperion.SerializerOptions..ctor(Boolean, Boolean, System.Collections.Generic.IEnumerable`1<Hyperion.Surrogate>, System.Collections.Generic.IEnumerable`1<Hyperion.SerializerFactories.ValueSerializerFactory>, System.Collections.Generic.IEnumerable`1<System.Type>)'.

Please any idea abt it?

I got during the creation of the ActorSystem

Arsene

@Tochemey

This exception stack:

System.Reflection.TargetInvocationException occurred
  HResult=0x80131604
  Message=Exception has been thrown by the target of an invocation.
  Source=mscorlib
  StackTrace:
   at System.RuntimeMethodHandle.InvokeMethod(Object target, Object[] arguments, Signature sig, Boolean constructor)
   at System.Reflection.RuntimeConstructorInfo.Invoke(BindingFlags invokeAttr, Binder binder, Object[] parameters, CultureInfo culture)
   at System.RuntimeType.CreateInstanceImpl(BindingFlags bindingAttr, Binder binder, Object[] args, CultureInfo culture, Object[] activationAttributes, StackCrawlMark& stackMark)
   at System.Activator.CreateInstance(Type type, BindingFlags bindingAttr, Binder binder, Object[] args, CultureInfo culture, Object[] activationAttributes)
   at System.Activator.CreateInstance(Type type, Object[] args)
   at Akka.Serialization.Serialization..ctor(ExtendedActorSystem system)
   at Akka.Actor.Internal.ActorSystemImpl..ctor(String name, Config config)
   at Akka.Actor.ActorSystem.Create(String name)


Inner Exception 1:
MissingMethodException: Method not found: 'Void Hyperion.SerializerOptions..ctor(Boolean, Boolean, System.Collections.Generic.IEnumerable`1<Hyperion.Surrogate>, System.Collections.Generic.IEnumerable`1<Hyperion.SerializerFactories.ValueSerializerFactory>, System.Collections.Generic.IEnumerable`1<System.Type>)'.

Arsene

@Tochemey

Oops I discovered the issue. It was package versioning while I was doing nuget update without enable pre-releasing for Hyperion. So I was referencing a wrong version.

Joshua Garnett

@joshgarnett

@alexvaluyskiy is your plan to add the dotcore support to the MySQL plugin before pushing to nuget?

Alex Valuyskiy

@alexvaluyskiy

yes

Joshua Garnett

@joshgarnett

Cool

Hopefully that’s not too painful

Alex Valuyskiy

@alexvaluyskiy

but something is going wrong with Mysql.Data

System.IO.FileLoadException : Could not load file or assembly 'MySql.Data, Version=8.0.8.0, Culture=neutral, PublicKeyToken=c5687fc88969c44d' or one of its dependencies. Strong name signature could not be verified.  The assembly may have been tampered with, or it was delay signed but not fully signed with the correct private key. (Exception from HRESULT: 0x80131045)

only in .NET 4.5 build, but it works fine with .Net Standard build

Joshua Garnett

@joshgarnett

huh

@alexvaluyskiy I think I see the issue, they are only including a dll for 452, my guess is if you up the project version to that it’ll work

Alex Valuyskiy

@alexvaluyskiy

mysql.data.6.10.3-rc contains a dll for net452 and for netstandard1.3

The problem is - netstandard one works fine, but net452 - not

Joshua Garnett

@joshgarnett

hmm you are right

weird

Alex Valuyskiy

@alexvaluyskiy

MySql.Data 6.9.9 works fine, but it does not support Net Standard

Joshua Garnett

@joshgarnett

it supports .netstandard1.3

Akka.net is 1.6, right?

Where communities thrive

People

Repo info

Activity