API tools faq
paste
martasd

db connection errors

martasd
Jan 19th, 2022 (edited)
156
0
Never
Add comment
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 18.45 KB | None | 0 0
raw download clone embed print report
  1. [debug] Locating aggregate process for `Core.Aggregates.UserAccount` with UUID "d89d392f-5c9d-490f-be85-8f215846a044"
  2. [error] an exception was raised logging %DBConnection.LogEntry{call: :prepare_execute, connection_time: 2426000, decode_time: 10000, idle_time: 436496000, params: ["d89d392f-5c9d-490f-be85-8f215846a044"], pool_time: 1822000, query: %Postgrex.Query{cache: :reference, columns: nil, name: "", param_formats: nil, param_oids: nil, param_types: nil, ref: nil, result_formats: nil, result_oids: nil, result_types: nil, statement: ["SELECT\n source_uuid,\n source_version,\n source_type,\n data,\n metadata,\n created_at\nFROM ", "public", ".snapshots\nWHERE source_uuid = $1;\n"], types: nil}, result: {:ok, %Postgrex.Query{cache: :reference, columns: ["source_uuid", "source_version", "source_type", "data", "metadata", "created_at"], name: "", param_formats: [:binary], param_oids: [25], param_types: [Postgrex.Extensions.Raw], ref: #Reference<0.578525844.1786249219.74982>, result_formats: [:binary, :binary, :binary, :binary, :binary, :binary], result_oids: [25, 20, 25, 17, 17, 1184], result_types: [Postgrex.Extensions.Raw, Postgrex.Extensions.Int8, Postgrex.Extensions.Raw, Postgrex.Extensions.Raw, Postgrex.Extensions.Raw, Postgrex.Extensions.TimestampTZ], statement: ["SELECT\n source_uuid,\n source_version,\n source_type,\n data,\n metadata,\n created_at\nFROM ", "public", ".snapshots\nWHERE source_uuid = $1;\n"], types: {Postgrex.DefaultTypes, #Reference<0.578525844.1786380291.73840>}}, %Postgrex.Result{columns: ["source_uuid", "source_version", "source_type", "data", "metadata", "created_at"], command: :select, connection_id: 11639, messages: [], num_rows: 0, rows: []}}}: ** (BadFunctionError) expected a function, got: false
  3. (db_connection 2.4.1) lib/db_connection.ex:1501: DBConnection.log/2
  4. (db_connection 2.4.1) lib/db_connection.ex:1479: DBConnection.log/5
  5. (postgrex 0.15.13) lib/postgrex.ex:313: Postgrex.query_prepare_execute/4
  6. (eventstore 1.3.2) lib/event_store/storage/snapshot.ex:14: EventStore.Storage.Snapshot.read_snapshot/3
  7. (eventstore 1.3.2) lib/event_store/snapshots/snapshotter.ex:13: EventStore.Snapshots.Snapshotter.read_snapshot/3
  8. (commanded_eventstore_adapter 1.2.0) lib/commanded/event_store/adapters/event_store.ex:121: Commanded.EventStore.Adapters.EventStore.read_snapshot/2
  9. (commanded 1.3.1) lib/commanded/snapshotting.ex:29: Commanded.Snapshotting.read_snapshot/1
  10. (commanded 1.3.1) lib/commanded/aggregates/aggregate_state_builder.ex:23: Commanded.Aggregates.AggregateStateBuilder.populate/1
  11. (commanded 1.3.1) lib/commanded/aggregates/aggregate.ex:264: Commanded.Aggregates.Aggregate.handle_continue/2
  12. (stdlib 3.17) gen_server.erl:695: :gen_server.try_dispatch/4
  13. (stdlib 3.17) gen_server.erl:437: :gen_server.loop/7
  14. (stdlib 3.17) proc_lib.erl:226: :proc_lib.init_p_do_apply/3
  15.  
  16. [error] an exception was raised logging %DBConnection.LogEntry{call: :prepare_execute, connection_time: 2248000, decode_time: 5000, idle_time: 476645000, params: [2, 1, 1000], pool_time: 2069000, query: %Postgrex.Query{cache: :reference, columns: nil, name: "", param_formats: nil, param_oids: nil, param_types: nil, ref: nil, result_formats: nil, result_oids: nil, result_types: nil, statement: ["SELECT\n se.stream_version,\n e.event_id,\n s.stream_uuid,\n se.original_stream_version,\n e.event_type,\n e.correlation_id,\n e.causation_id,\n e.data,\n e.metadata,\n e.created_at\nFROM ", "public", ".stream_events se\nINNER JOIN ", "public", ".streams s ON s.stream_id = se.original_stream_id\nINNER JOIN ", "public", ".events e ON se.event_id = e.event_id\nWHERE\n se.stream_id = $1 AND se.stream_version >= $2\nORDER BY\n se.stream_version ASC\nLIMIT $3;\n"], types: nil}, result: {:ok, %Postgrex.Query{cache: :reference, columns: ["stream_version", "event_id", "stream_uuid", "original_stream_version", "event_type", "correlation_id", "causation_id", "data", "metadata", "created_at"], name: "", param_formats: [:binary, :binary, :binary], param_oids: [20, 20, 20], param_types: [Postgrex.Extensions.Int8, Postgrex.Extensions.Int8, Postgrex.Extensions.Int8], ref: #Reference<0.578525844.1786249217.86382>, result_formats: [:binary, :binary, :binary, :binary, :binary, :binary, :binary, :binary, :binary, :binary], result_oids: [20, 2950, 25, 20, 25, 2950, 2950, 17, 17, 1184], result_types: [Postgrex.Extensions.Int8, Postgrex.Extensions.UUID, Postgrex.Extensions.Raw, Postgrex.Extensions.Int8, Postgrex.Extensions.Raw, Postgrex.Extensions.UUID, Postgrex.Extensions.UUID, Postgrex.Extensions.Raw, Postgrex.Extensions.Raw, Postgrex.Extensions.TimestampTZ], statement: ["SELECT\n se.stream_version,\n e.event_id,\n s.stream_uuid,\n se.original_stream_version,\n e.event_type,\n e.correlation_id,\n e.causation_id,\n e.data,\n e.metadata,\n e.created_at\nFROM ", "public", ".stream_events se\nINNER JOIN ", "public", ".streams s ON s.stream_id = se.original_stream_id\nINNER JOIN ", "public", ".events e ON se.event_id = e.event_id\nWHERE\n se.stream_id = $1 AND se.stream_version >= $2\nORDER BY\n se.stream_version ASC\nLIMIT $3;\n"], types: {Postgrex.DefaultTypes, #Reference<0.578525844.1786380291.73840>}}, %Postgrex.Result{columns: ["stream_version", "event_id", "stream_uuid", "original_stream_version", "event_type", "correlation_id", "causation_id", "data", "metadata", "created_at"], command: :select, connection_id: 11635, messages: [], num_rows: 5, rows: [[1, <<193, 222, 228, 243, 145, 84, 70, 133, 167, 116, 134, 250, 70, 201, 71, 112>>, "d89d392f-5c9d-490f-be85-8f215846a044", 1, "Elixir.Core.Events.CreateIbisAccount.Request", <<5, 157, 143, 105, 68, 8, 72, 29, 190, 147, 222, 99, 140, 211, 12, 5>>, <<20, 180, 103, 121, 70, 2, 76, 122, 184, 173, 14, 24, 152, 75, 61, 239>>, "{\"customer\", "{}", ~U[2022-01-14 09:10:17.841907Z]], [2, <<110, 171, 87, 144, 138, 237, 64, 57, 184, 118, 52, 49, 177, 116, 175, 86>>, "d89d392f-5c9d-490f-be85-8f215846a044", 2, "Elixir.Core.Events.CreateIbisAccount.Success", <<5, 157, 143, 105, 68, 8, 72, 29, 190, 147, 222, 99, 140, 211, 12, 5>>, <<42, 124, 158, 145, 252, 126, 73, 171, 164, 75, 45, 30, 139, 177, 69, 82>>, "{}", ~U[2022-01-14 09:10:20.349524Z]], [3, <<174, 191, 54, 97, 162, 210, 67, 58, 136, 3, 219, 52, 48, 101, 149, 66>>, "d89d392f-5c9d-490f-be85-8f215846a044", 3, "Elixir.Core.Events.CreateFinApiAccount.Request", <<5, 157, 143, 105, 68, 8, 72, 29, 190, 147, 222, 99, 140, 211, 12, 5>>, <<133, 194, 221, 189, 34, 81, 69, 145, 191, 195, 248, 254, 105, 113, 168, 158>>, "{}", ~U[2022-01-14 09:10:21.057204Z]], [5, <<151, 142, 144, 148, 138, 137, 70, 53, 163, 30, 122, 242, 55, 33, 72, 55>>, "d89d392f-5c9d-490f-be85-8f215846a044", 5, "Elixir.Core.Events.UserCreated", <<5, 157, 143, 105, 68, 8, 72, 29, 190, 147, 222, 99, 140, 211, 12, 5>>, <<22, 51, 100, 29, 103, 241, 79, 61, 175, 35, 51, 248, 210, 58, 122, 230>>, "{}", ~U[2022-01-14 09:10:21.100995Z]]]}}}: ** (BadFunctionError) expected a function, got: false
  17. (db_connection 2.4.1) lib/db_connection.ex:1501: DBConnection.log/2
  18. (db_connection 2.4.1) lib/db_connection.ex:1479: DBConnection.log/5
  19. (postgrex 0.15.13) lib/postgrex.ex:313: Postgrex.query_prepare_execute/4
  20. (eventstore 1.3.2) lib/event_store/storage/reader.ex:128: EventStore.Storage.Reader.Query.do_query/4
  21. (eventstore 1.3.2) lib/event_store/storage/reader.ex:14: EventStore.Storage.Reader.read_forward/5
  22. (eventstore 1.3.2) lib/event_store/streams/stream.ex:242: EventStore.Streams.Stream.read_storage_forward/5
  23. (eventstore 1.3.2) lib/event_store/streams/stream.ex:272: anonymous fn/5 in EventStore.Streams.Stream.stream_storage_forward/4
  24. (elixir 1.12.3) lib/stream.ex:1531: Stream.do_resource/5
  25. (elixir 1.12.3) lib/stream.ex:1719: Enumerable.Stream.do_each/4
  26. (elixir 1.12.3) lib/enum.ex:3958: Enum.reduce/3
  27. (commanded 1.3.1) lib/commanded/aggregates/aggregate.ex:264: Commanded.Aggregate (truncated)
  28. [error] an exception was raised logging %DBConnection.LogEntry{call: :prepare_execute, connection_time: 2621000, decode_time: 8000, idle_time: 526099000, params: [2, 6, 1000], pool_time: 2532000, query: %Postgrex.Query{cache: :reference, columns: nil, name: "", param_formats: nil, param_oids: nil, param_types: nil, ref: nil, result_formats: nil, result_oids: nil, result_types: nil, statement: ["SELECT\n se.stream_version,\n e.event_id,\n s.stream_uuid,\n se.original_stream_version,\n e.event_type,\n e.correlation_id,\n e.causation_id,\n e.data,\n e.metadata,\n e.created_at\nFROM ", "public", ".stream_events se\nINNER JOIN ", "public", ".streams s ON s.stream_id = se.original_stream_id\nINNER JOIN ", "public", ".events e ON se.event_id = e.event_id\nWHERE\n se.stream_id = $1 AND se.stream_version >= $2\nORDER BY\n se.stream_version ASC\nLIMIT $3;\n"], types: nil}, result: {:ok, %Postgrex.Query{cache: :reference, columns: ["stream_version", "event_id", "stream_uuid", "original_stream_version", "event_type", "correlation_id", "causation_id", "data", "metadata", "created_at"], name: "", param_formats: [:binary, :binary, :binary], param_oids: [20, 20, 20], param_types: [Postgrex.Extensions.Int8, Postgrex.Extensions.Int8, Postgrex.Extensions.Int8], ref: #Reference<0.578525844.1786249217.86442>, result_formats: [:binary, :binary, :binary, :binary, :binary, :binary, :binary, :binary, :binary, :binary], result_oids: [20, 2950, 25, 20, 25, 2950, 2950, 17, 17, 1184], result_types: [Postgrex.Extensions.Int8, Postgrex.Extensions.UUID, Postgrex.Extensions.Raw, Postgrex.Extensions.Int8, Postgrex.Extensions.Raw, Postgrex.Extensions.UUID, Postgrex.Extensions.UUID, Postgrex.Extensions.Raw, Postgrex.Extensions.Raw, Postgrex.Extensions.TimestampTZ], statement: ["SELECT\n se.stream_version,\n e.event_id,\n s.stream_uuid,\n se.original_stream_version,\n e.event_type,\n e.correlation_id,\n e.causation_id,\n e.data,\n e.metadata,\n e.created_at\nFROM ", "public", ".stream_events se\nINNER JOIN ", "public", ".streams s ON s.stream_id = se.original_stream_id\nINNER JOIN ", "public", ".events e ON se.event_id = e.event_id\nWHERE\n se.stream_id = $1 AND se.stream_version >= $2\nORDER BY\n se.stream_version ASC\nLIMIT $3;\n"], types: {Postgrex.DefaultTypes, #Reference<0.578525844.1786380291.73840>}}, %Postgrex.Result{columns: ["stream_version", "event_id", "stream_uuid", "original_stream_version", "event_type", "correlation_id", "causation_id", "data", "metadata", "created_at"], command: :select, connection_id: 11638, messages: [], num_rows: 0, rows: []}}}: ** (BadFunctionError) expected a function, got: false
  29. (db_connection 2.4.1) lib/db_connection.ex:1501: DBConnection.log/2
  30. (db_connection 2.4.1) lib/db_connection.ex:1479: DBConnection.log/5
  31. (postgrex 0.15.13) lib/postgrex.ex:313: Postgrex.query_prepare_execute/4
  32. (eventstore 1.3.2) lib/event_store/storage/reader.ex:128: EventStore.Storage.Reader.Query.do_query/4
  33. (eventstore 1.3.2) lib/event_store/storage/reader.ex:14: EventStore.Storage.Reader.read_forward/5
  34. (eventstore 1.3.2) lib/event_store/streams/stream.ex:242: EventStore.Streams.Stream.read_storage_forward/5
  35. (eventstore 1.3.2) lib/event_store/streams/stream.ex:272: anonymous fn/5 in EventStore.Streams.Stream.stream_storage_forward/4
  36. (elixir 1.12.3) lib/stream.ex:1531: Stream.do_resource/5
  37. (elixir 1.12.3) lib/stream.ex:1719: Enumerable.Stream.do_each/4
  38. (elixir 1.12.3) lib/enum.ex:3958: Enum.reduce/3
  39. (commanded 1.3.1) lib/commanded/aggregates/aggregate.ex:264: Commanded.Aggregates.Aggregate.handle_continue/2
  40. (stdlib 3.17) gen_server.erl:695: :gen_server.try_dispatch/4
  41. (stdlib 3.17) gen_server.erl:437: :gen_server.loop/7
  42. (stdlib 3.17) proc_lib.erl:226: :proc_lib.init_p_do_apply/3
  43.  
  44. [debug] Core.Aggregates.UserAccount<d89d392f-5c9d-490f-be85-8f215846a044@5> executing command: %Core.Commands.SetData{date: ~D[2021-11-14], position: %{lat: #Decimal<42.331429>, lon: #Decimal<-83.045753>}, steps: 9000, user_uuid: "d89d392f-5c9d-490f-be85-8f215846a044"}
  45. [debug] Listener received notification on channel "public.events" with payload: "$all,0,16,16"
  46. [error] an exception was raised logging %DBConnection.LogEntry{call: :prepare_execute, connection_time: 15403000, decode_time: 3000, idle_time: 116065000, params: [2, 1, <<117, 120, 145, 173, 214, 25, 64, 174, 169, 254, 214, 78, 135, 50, 95, 25>>, "Elixir.Core.Events.DataSet", <<197, 195, 178, 90, 223, 188, 66, 27, 144, 206, 10, 109, 77, 139, 0, 163>>, <<167, 154, 208, 15, 247, 70, 65, 91, 149, 233, 61, 231, 42, 220, 107, 16>>, "{\"date\":\"2021-11-14\",\"position\":{\"lat\":\"42.331429\",\"lon\":\"-83.045753\"},\"steps\":9000,\"user_uuid\":\"d89d392f-5c9d-490f-be85-8f215846a044\"}", "{}", ~U[2022-01-19 09:43:21.588582Z], 1, 6], pool_time: 8547000, query: %Postgrex.Query{cache: :reference, columns: nil, name: "", param_formats: nil, param_oids: nil, param_types: nil, ref: nil, result_formats: nil, result_oids: nil, result_types: nil, statement: ["WITH\n new_events_indexes (event_id, index, stream_version) AS (\n VALUES\n ", "\n \n ($3::uuid, $10::int, $11::bigint)\n ", "\n ),\n events AS (\n INSERT INTO ", "public", ".events\n (\n event_id,\n event_type,\n causation_id,\n correlation_id,\n data,\n metadata,\n created_at\n )\n VALUES\n ", "\n \n ($3, $4, $5, $6, $7, $8, $9)\n ", "\n ),\n stream AS (\n ", "\n UPDATE public.streams\n SET stream_version = stream_version + $2::bigint\n WHERE stream_id = $1::bigint\n returning stream_id\n ", "\n ),\n source_stream_events AS (\n INSERT INTO ", "public", ".stream_events\n (\n event_id,\n stream_id,\n stream_version,\n original_stream_id,\n original_stream_version\n )\n SELECT\n new_events_indexes.event_id,\n stream.stream_id,\n new_events_indexes.stream_version,\n stream.stream_id,\n new_events_indexes.stream_version\n FROM new_events_indexes, stream\n ),\n linked_stream AS (\n UPDATE ", "public", ".streams\n SET stream_version = stream_version + $2::bigint\n WHERE stream_id = 0\n RETURNING stream_version - $2::bigint as initial_stream_version\n )\nINSERT INTO ", "public", ".stream_events\n(\n event_id,\n stream_id,\n stream_version,\n original_stream_id,\n original_stream_version\n)\nSELECT\n new_events_indexes.event_id,\n 0,\n linked_stream.initial_stream_version + new_events_indexes.index,\n stream.stream_id,\n new_events_indexes.stream_version\nFROM\n new_events_indexes, linked_stream, stream;\n"], types: nil}, result: {:ok, %Postgrex.Query{cache: :reference, columns: nil, name: "", param_formats: [:binary, :binary, :binary, :binary, :binary, :binary, :binary, :binary, :binary, :binary, :binary], param_oids: [20, 20, 2950, 25, 2950, 2950, 17, 17, 1184, 23, 20], param_types: [Postgrex.Extensions.Int8, Postgrex.Extensions.Int8, Postgrex.Extensions.UUID, Postgrex.Extensions.Raw, Postgrex.Extensions.UUID, Postgrex.Extensions.UUID, Postgrex.Extensions.Raw, Postgrex.Extensions.Raw, Postgrex.Extensions.TimestampTZ, Postgrex.Extensions.Int4, Postgrex.Extensions.Int8], ref: #Reference<0.578525844.1786249219.75028>, result_formats: [], result_oids: nil, result_types: nil, statement: ["WITH\n new_events_indexes (event_id, index, stream_version) AS (\n VALUES\n ", "\n \n ($3::uuid, $10::int, $11::bigint)\n ", "\n ),\n events AS (\n INSERT INTO ", "public", ".events\n (\n event_id,\n event_type,\n causation_id,\n correlation_id,\n data,\n metadata,\n created_at\n )\n VALUES\n ", "\n \n ($3, $4, $5, $6, $7, $8, $9)\n ", "\n ),\n stream AS (\n ", "\n UPDATE public.streams\n SET stream_version = stream_version + $2::bigint\n WHERE stream_id = $1::bigint\n returning stream_id\n ", "\n ),\n source_stream_events AS (\n INSERT INTO ", "public", ".stream_events\n (\n event_id,\n stream_id,\n stream_version,\n original_stream_id,\n original_stream_version\n )\n SELECT\n new_events_indexes.event_id,\n stream.stream_id,\n new_events_indexes.stream_version,\n stream.stream_id,\n new_events_indexes.stream_version\n FROM new_events_indexes, stream\n ),\n linked_stream AS (\n UPDATE ", "public", ".streams\n SET stream_version = stream_version + $2::bigint\n WHERE stream_id = 0\n RETURNING stream_version - $2::bigint as initial_stream_version\n )\nINSERT INTO ", "public", ".stream_events\n(\n event_id,\n stream_id,\n stream_version,\n original_stream_id,\n original_stream_version\n)\nSELECT\n new_events_indexes.event_id,\n 0,\n linked_stream.initial_stream_version + new_events_indexes.index,\n stream.stream_id,\n new_events_indexes.stream_version\nFROM\n new_events_indexes, linked_stream, stream;\n"], types: {Postgrex.DefaultTypes, #Reference<0.578525844.1786380291.73840>}}, %Postgrex.Result{columns: nil, command: :insert, connection_id: 11639, messages: [], num_rows: 1, rows: nil}}}: ** (BadFunctionError) expected a function, got: false
  47. (db_connection 2.4.1) lib/db_connection.ex:1501: DBConnection.log/2
  48. (db_connection 2.4.1) lib/db_connection.ex:1479: DBConnection.log/5
  49. (postgrex 0.15.13) lib/postgrex.ex:313: Postgrex.query_prepare_execute/4
  50. (eventstore 1.3.2) lib/event_store/storage/appender.ex:114: EventStore.Storage.Appender.insert_event_batch/6
  51. (eventstore 1.3.2) lib/event_store/storage/appender.ex:27: anonymous fn/5 in EventStore.Storage.Appender.append/4
  52. (elixir 1.12.3) lib/enum.ex:935: anonymous fn/3 in Enum.each/2
  53. (elixir 1.12.3) lib/enum.ex:3958: anonymous fn/3 in Enum.each/2
  54. (elixir 1.12.3) lib/stream.ex:1707: anonymous fn/3 in Enumerable.Stream.reduce/3
  55. (elixir 1.12.3) lib/stream.ex:285: Stream.after_chunk_while/2
  56. (elixir 1.12.3) lib/stream.ex:1736: Enumerable.Stream.do_done/2
  57. (elixir 1.12.3) lib/enum.ex:3958: Enum.each/2
  58. (eventstore 1.3.2) lib/event_store/storage/appender.ex:24: EventStore.Storage.Appender.append/4
  59. (eventstore 1.3.2) lib/event_store/streams/stream.ex:12: EventStore.Streams.Stream.append_to_stream/5
  60. (commanded 1.3.1) lib/commanded/aggregates/aggregate.ex:537: Commanded.Aggregates.Aggregate.persist_events/4
  61. (commanded 1.3.1) lib/commanded/aggregates/aggregate.ex:507: Commanded.Aggregates.Aggregate.execute_command/2
  62. (commanded 1.3.1) lib/commanded/aggregates/aggregate.ex:317: Commanded.Aggregates.Aggregate.handle_call/3
  63. (stdlib 3.17) gen_server.erl:721: :gen_server.try_handle_call/4
  64. (stdlib 3.17) gen_server.erl:750: :gen_server.handle_msg/6
  65. (stdlib 3.17) proc_lib.erl:226: :proc_lib.init_p_do_apply/3
Add Comment
Please, Sign In to add comment
Public Pastes
We use cookies for various purposes including analytics. By continuing to use Pastebin, you agree to our use of cookies as described in the Cookies Policy.  OK, I Understand
Not a member of Pastebin yet?
Sign Up, it unlocks many cool features!