図面をクリックすると記事に飛びます。
create extension postgis で止ってしまう件
以下、自分用のメモのみ
AWS Lightsailにdockerのインストールまで成功
↓
が、ここから嵌り始める。
ca_sim=# create extension postgis;
^C^CCancel request sent
Cancel request sent
ERROR: canceling statement due to user request
server closed the connection unexpectedly
This probably means the server terminated abnormally
before or while processing the request.
The connection to the server was lost. Attempting reset: Failed.
!>
が出てきて、
サーバ側に
2020-11-04 12:52:16.858 UTC [51] ERROR: canceling statement due to user request
2020-11-04 12:52:16.858 UTC [51] STATEMENT: create extension postgis;
2020-11-04 12:53:53.365 UTC [1] LOG: server process (PID 51) was terminated by signal 9: Killed
2020-11-04 12:53:53.365 UTC [1] DETAIL: Failed process was running: create extension postgis;
2020-11-04 12:53:53.365 UTC [1] LOG: terminating any other active server processes
2020-11-04 12:53:53.367 UTC [25] WARNING: terminating connection because of crash of another server process
2020-11-04 12:53:53.367 UTC [25] DETAIL: The postmaster has commanded this server process to roll back the current transaction and exit, because another server process exited abnormally and possibly corrupted shared memory.
2020-11-04 12:53:53.367 UTC [25] HINT: In a moment you should be able to reconnect to the database and repeat your command.
2020-11-04 12:53:53.371 UTC [53] WARNING: terminating connection because of crash of another server process
2020-11-04 12:53:53.371 UTC [53] DETAIL: The postmaster has commanded this server process to roll back the current transaction and exit, because another server process exited abnormally and possibly corrupted shared memory.
2020-11-04 12:53:53.371 UTC [53] HINT: In a moment you should be able to reconnect to the database and repeat your command.
2020-11-04 12:53:53.372 UTC [56] WARNING: terminating connection because of crash of another server process
2020-11-04 12:53:53.372 UTC [56] DETAIL: The postmaster has commanded this server process to roll back the current transaction and exit, because another server process exited abnormally and possibly corrupted shared memory.
2020-11-04 12:53:53.372 UTC [56] HINT: In a moment you should be able to reconnect to the database and repeat your command.
2020-11-04 12:53:53.516 UTC [1] LOG: all server processes terminated; reinitializing
2020-11-04 12:53:53.535 UTC [58] FATAL: the database system is in recovery mode
2020-11-04 12:53:53.538 UTC [57] LOG: database system was interrupted; last known up at 2020-11-04 12:47:18 UTC
2020-11-04 12:53:53.607 UTC [57] LOG: database system was not properly shut down; automatic recovery in progress
2020-11-04 12:53:53.613 UTC [57] LOG: redo starts at 0/216DCD0
2020-11-04 12:53:53.712 UTC [57] LOG: invalid record length at 0/24F2310: wanted 24, got 0
2020-11-04 12:53:53.712 UTC [57] LOG: redo done at 0/24F22D8
2020-11-04 12:53:53.741 UTC [1] LOG: database system is ready to accept connections
そこで、
コンテナの外に出て、
sudo apt-get clean
sudo apt-get install postgis
sudo apt-get update
■全部のDockerを止める
C:\Users\ebata>docker ps -aq | xargs docker stop
C:\Users\ebata>docker ps -aq | xargs docker rm (これやると、これまでの設定も全滅するので注意)
もう一度、imageから作り直して ・・(30分経過)・・ううむ、それでもダメか。
今日はここで一旦引き上げ
自分の誕生日に魚料理を作らされる父親
江端家では、時々ネットで鮮魚を取り寄せて、食しているのですが、なぜか私が料理をさせられることが多いようです ―― 私の誕生日に、私が料理させられるのです。
大切なのは、ここです。
下処理した魚が送られてくるので、魚を鍋かグリルに放り込むだけで魚料理が完成します(刺身とかを作るときは、3枚に卸すなどが必要ですが)。
今日、送られてきた魚一覧です。
- 的たい
まあ、これは3枚にしてあるから、刺身で決定。
- うすばはぎ
これは煮つけで確定。 - ぐじ
塩焼か煮つけか？ - 天然真鯛
なんか、凄いのきた。塩焼で食べたいかな。上手く刺身にする自信がない - 白そい八目
ネットで見ると、刺身が多いみたいだが、ちょっと面倒そう - のどくろ
塩焼が良い、との記載がある。煮付けなら簡単だが、どうしよう。
まあ、今の私達には、「めんつゆ」という強力な武器があるから、「煮付け」はについては、昔ほど面倒じゃないですけど。
今日のコード
■サーバ側で、通信エラーが発生したら、問答無用でbreakしてループの外に追い出した。
/*
// server13.go ペアはclient8.go
// Copyright 2015 The Gorilla WebSocket Authors. All rights reserved.
// Use of this source code is governed by a BSD-style
// license that can be found in the LICENSE file.
// +build ignore
// 使い方
// go run server13.go (適当なシェルから)
// http://localhost:8080 (ブラウザ起動)
*/
package main
import (
"flag"
"fmt"
"html/template"
"log"
"net/http"
"sync"
"github.com/gorilla/websocket"
)
// GetLoc GetLoc
type GetLoc struct {
ID int `json:"id"`
Lat float64 `json:"lat"`
Lng float64 `json:"lng"`
//Address string `json:"address"`
}
//var addr = flag.String("addr", "localhost:8080", "http service address")
var addr = flag.String("addr", "0.0.0.0:8080", "http service address") // テスト
var upgrader = websocket.Upgrader{} // use default options
var chan2_1 = make(chan GetLoc)
var maxid = 0
var mutex sync.Mutex
func echo2(w http.ResponseWriter, r *http.Request) {
c, err := upgrader.Upgrade(w, r, nil) // cはサーバのコネクション
if err != nil {
log.Print("upgrade:", err)
return
}
defer c.Close()
//mutex := new(sync.Mutex)
for {
//mt, message, err := c.ReadMessage() // クライアントからのメッセージの受信(mtはクライアント識別子)
//_, _, err := c.ReadMessage() // クライアントからのメッセージの受信(mtはクライアント識別子)
mutex.Lock()
gl := new(GetLoc)
err := c.ReadJSON(&gl) // クライアントからのメッセージの受信
// 原因不明の対処処理
if gl.ID == 0 && gl.Lat < 0.01 && gl.Lng < 0.01 {
mutex.Unlock()
break
} else if gl.ID < -1 { // 受理できないメッセージとして返信する
//条件分岐 (変なIDが付与されているメッセージは潰す)
//if (gl.ID > maxid) || (gl.ID < -1) { // 受理できないメッセージとして返信する
gl.ID = -1
gl.Lat = -999
gl.Lng = -999
err2 := c.WriteJSON(gl)
if err2 != nil {
log.Println("write1:", err2)
break
}
} else { // それ以外は転送する
log.Printf("echo2 after c.WriteJSON(gl) ID:%d", gl.ID)
log.Printf("echo2 after c.WriteJSON(gl) Lat:%f", gl.Lat)
log.Printf("echo2 after c.WriteJSON(gl) Lng:%f", gl.Lng)
if err != nil {
log.Println("read:", err)
break
}
fmt.Printf("echo2 before chan2_1 <- *gl\n")
chan2_1 <- *gl
fmt.Printf("echo2 after chan2_1 <- *gl\n")
//で、ここで受けとる
//gl2 := new(GetLoc)
fmt.Printf("echo2 before gl2 := <-chan2_1\n")
gl2 := <-chan2_1
maxid = gl2.ID // ID最大値の更新
log.Printf("echo2 after gl2 := <-chan2_1 ID:%d", gl2.ID)
log.Printf("echo2 after gl2 := <-chan2_1 Lat:%f", gl2.Lat)
log.Printf("echo2 after gl2 := <-chan2_1 Lng:%f", gl2.Lng)
fmt.Printf("echo2 before err2 := c.WriteJSON(gl2)\n")
err2 := c.WriteJSON(gl2)
fmt.Printf("echo2 after err2 := c.WriteJSON(gl2)\n")
if err2 != nil {
log.Println("write2:", err2)
break
}
fmt.Printf("end of echo2\n")
}
mutex.Unlock()
}
}
func echo(w http.ResponseWriter, r *http.Request) {
c, err := upgrader.Upgrade(w, r, nil) // cはサーバのコネクション
if err != nil {
log.Print("upgrade:", err)
return
}
defer c.Close()
/* ここでロックして待つ */
for {
fmt.Printf("echo before gl := <-chan2_1\n")
gl := <-chan2_1
fmt.Printf("echo after gl := <-chan2_1\n")
fmt.Printf("echo before err = c.WriteJSON(gl) gl2.id = %d\n", gl.ID)
fmt.Printf("echo before err = c.WriteJSON(gl) gl2.lat = %f\n", gl.Lat)
fmt.Printf("echo before err = c.WriteJSON(gl) gl2.lng= %f\n", gl.Lng)
err = c.WriteJSON(gl)
if err != nil {
log.Println("WriteJSON1:", err)
}
fmt.Printf("echo after err = c.WriteJSON(gl)\n")
fmt.Printf("echo before err = c.RreadJSON(gl)\n")
gl2 := new(GetLoc)
err2 := c.ReadJSON(&gl2)
fmt.Printf("echo after err = c.ReadJSON(&gl2) gl2.id = %d\n", gl2.ID)
fmt.Printf("echo after err = c.ReadJSON(&gl2) gl2.lat = %f\n", gl2.Lat)
fmt.Printf("echo after err = c.ReadJSON(&gl2) gl2.lng= %f\n", gl2.Lng)
if err2 != nil {
log.Println("ReadJSON:", err2)
}
// ここからチャネルで返す
fmt.Printf("echo before chan2_1 <- *gl2 gl2.id = %d\n", gl2.ID)
fmt.Printf("echo before chan2_1 <- *gl2 gl2.lat = %f\n", gl2.Lat)
fmt.Printf("echo before chan2_1 <- *gl2 gl2.lng = %f\n", gl2.Lng)
chan2_1 <- *gl2
fmt.Printf("echo after chan2_1 <- *gl2\n")
fmt.Printf("end of echo\n")
}
}
func home(w http.ResponseWriter, r *http.Request) {
homeTemplate.Execute(w, "ws://"+r.Host+"/echo")
}
func main() {
flag.Parse()
log.SetFlags(0)
http.HandleFunc("/echo2", echo2) // echo関数を登録 (サーバとして必要)
http.HandleFunc("/echo", echo) // echo関数を登録 (サーバとして必要)
http.HandleFunc("/", home) // home関数を登録
log.Fatal(http.ListenAndServe(*addr, nil)) // localhost:8080で起動をセット
}
var homeTemplate = template.Must(template.New("").Parse(`
<!DOCTYPE html>
<html lang="en">
<head>
<meta charset="utf-8" />
<title>PruneCluster - Realworld 50k</title>
<link rel="stylesheet" href="https://cdnjs.cloudflare.com/ajax/libs/leaflet/1.0.0-beta.2.rc.2/leaflet.css"/>
<script src="https://cdnjs.cloudflare.com/ajax/libs/leaflet/1.0.0-beta.2.rc.2/leaflet.js"></script>
<script src="http://kobore.net/PruneCluster.js"></script> <!-- これ、いずれローカルホストから取れるように換える -->
<link rel="stylesheet" href="http://kobore.net/examples.css"/> <!-- これも、いずれローカルホストから取れるように換える -->
<!-- goのテンプレートのローカルって、どこになるんだろう？ -->
</head>
<body>
<div id="map"></div>
<script>
ws = new WebSocket("{{.}}"); // websocketの確立
/*
var print = function(message) {
var d = document.createElement("div");
d.textContent = message;
output.appendChild(d);
};
*/
// 引数にはミリ秒を指定。（例：5秒の場合は5000）
function sleep(a){
var dt1 = new Date().getTime();
var dt2 = new Date().getTime();
while (dt2 < dt1 + a){
dt2 = new Date().getTime();
}
return;
}
var map = L.map("map", {
attributionControl: false,
zoomControl: false
}).setView(new L.LatLng(35.654543, 139.795534), 18);
L.tileLayer('http://{s}.tile.osm.org/{z}/{x}/{y}.png', {
detectRetina: true,
maxNativeZoom: 18
}).addTo(map);
var leafletView = new PruneClusterForLeaflet(1,1); // (120,20)がデフォルト
ws.onopen = function (event) {
}
var markers = [];
// 受信すると、勝手にここに飛んでくる
ws.onmessage = function (event) {
// データをJSON形式に変更
var obj = JSON.parse(event.data);
console.log("233");
console.log(obj.id);
console.log(obj.lat);
console.log(obj.lng);
if (obj.id == 0){ // idが未登録の場合
console.log("obj.id == 0")
// データをマーカーとして登録
var marker = new PruneCluster.Marker(obj.lat, obj.lng);
console.log(marker.hashCode);
markers.push(marker);
leafletView.RegisterMarker(marker);
console.log(markers);
console.log(markers.length)
obj.id = marker.hashCode;
//ws.send(marker.hashCode); // テキスト送信
var json_obj = JSON.stringify(obj);
ws.send(json_obj);
} else if ((Math.abs(obj.lat) > 90.0) || (Math.abs(obj.lng) > 180.0)){ // 異常な座標が入った場合は、マーカーを消去する
console.log("Math.abs(obj.lat) > 180.0)")
for (let i = 0; i < markers.length; ++i) {
if (obj.id == markers[i].hashCode){
console.log(i)
console.log(obj.id)
console.log("obj.id == markers[i].hashCode")
leafletView.RemoveMarkers(markers[obj.id]);
//leafletView.RemoveMarkers(markers[i-1]);
//leafletView.RemoveMarkers(markers);
break;
}
}
obj.lat = 91.0;
obj.lng = 181.0;
var json_obj = JSON.stringify(obj);
ws.send(json_obj);
} else {
// 位置情報更新
console.log("else")
for (let i = 0; i < markers.length; ++i) {
if (obj.id == markers[i].hashCode){
var ll = markers[i].position;
ll.lat = obj.lat;
ll.lng = obj.lng;
break;
}
}
var json_obj = JSON.stringify(obj);
ws.send(json_obj);
}
}
// 位置情報の更新
window.setInterval(function () {
leafletView.ProcessView(); // 変更が行われたときに呼び出されれなければならない
}, 1000);
// サーバを止めると、ここに飛んでくる
ws.onclose = function(event) {
//print("CLOSE");
ws = null;
}
map.addLayer(leafletView);
</script>
</body>
</html>
`))■クライアント側は、1000個のGoルーチンが全部終わるまで待つようにした
func main() {
var wg sync.WaitGroup
for i := 1; i < 1000; i++ {
wg.Add(1) // goルーチンを実行する関数分だけAddする。
go passenger(i, &wg)
}
// goルーチンで実行される関数が終了するまで待つ。
wg.Wait()
// time.Sleep(250 * time.Second)
}
func passenger(count int, wg *sync.WaitGroup) {
////.............................
}■クライアントプログラムは以下の通り
// client8.go ペアは server13.go
package main
import (
"flag"
"log"
"net/url"
"sync"
"github.com/gorilla/websocket"
"math/rand"
"time"
)
// GetLoc GetLoc
type GetLoc struct {
ID int `json:"id"`
Lat float64 `json:"lat"`
Lng float64 `json:"lng"`
//Address string `json:"address"`
}
var addr = flag.String("addr", "0.0.0.0:8080", "http service address") // テスト
func random(min, max float64) float64 {
return rand.Float64()*(max-min) + min
}
func main() {
var wg sync.WaitGroup
for i := 1; i < 1000; i++ {
wg.Add(1) // goルーチンを実行する関数分だけAddする。
go passenger(i, &wg)
}
// goルーチンで実行される関数が終了するまで待つ。
wg.Wait()
// time.Sleep(250 * time.Second)
}
func passenger(count int, wg *sync.WaitGroup) {
//var addr = flag.String("addr", "0.0.0.0:8080", "http service address") // テスト
//var addr = flag.String("addr", "localhost:8080", "http service address") // テスト
defer wg.Done() // WaitGroupを最後に完了しないといけない。
//var upgrader = websocket.Upgrader{} // use default options
_ = websocket.Upgrader{} // use default options
rand.Seed(time.Now().UnixNano())
flag.Parse()
log.SetFlags(0)
u := url.URL{Scheme: "ws", Host: *addr, Path: "/echo2"}
log.Printf("connecting to %s", u.String())
c, _, err := websocket.DefaultDialer.Dial(u.String(), nil)
if err != nil {
log.Fatal("dial:", err)
}
defer c.Close()
gl := GetLoc{
ID: 0,
Lat: 35.653976,
Lng: 139.796821,
}
log.Printf("count:%d before 1 ID:%d", count, gl.ID)
log.Printf("count:%d before 1 Lat:%f", count, gl.Lat)
log.Printf("count:%d before 1 Lng:%f", count, gl.Lng)
//err = c.WriteJSON(mt, gl)
err = c.WriteJSON(gl)
if err != nil {
log.Println("write:", err)
}
gl2 := new(GetLoc)
err = c.ReadJSON(gl2)
log.Printf("count:%d after1 ID:%d", count, gl2.ID)
log.Printf("count:%d after1 Lat:%f", count, gl2.Lat)
log.Printf("count:%d after1 Lng:%f", count, gl2.Lng)
gl.ID = gl2.ID
for i := 0; i < 20; i++ {
gl.Lat += random(0.5, -0.5) * 0.00001 * 10 * 5
gl.Lng += random(0.5, -0.5) * 0.00002 * 10 * 5
log.Printf("count:%d-%d before 2 ID:%d", count, i, gl.ID)
log.Printf("count:%d-%d before 2 Lat:%f", count, i, gl.Lat)
log.Printf("count:%d-%d before 2 Lng:%f", count, i, gl.Lng)
err = c.WriteJSON(gl)
if err != nil {
log.Println("write:", err)
}
gl2 := new(GetLoc)
err = c.ReadJSON(gl2)
log.Printf("count:%d-%d after 2 ID:%d", count, i, gl2.ID)
log.Printf("count:%d-%d after 2 Lat:%f", count, i, gl2.Lat)
log.Printf("count:%d-%d after 2 Lng:%f", count, i, gl2.Lng)
time.Sleep(1 * time.Second) // 1秒休む
}
gl.ID = gl2.ID
gl.Lat = 999.9
gl.Lng = 999.9
log.Printf("count:%d before 3 ID:%d", count, gl.ID)
log.Printf("count:%d before 3 Lat:%f", count, gl.Lat)
log.Printf("count:%d before 3 Lng:%f", count, gl.Lng)
err = c.WriteJSON(gl)
err = c.ReadJSON(gl2)
log.Printf("count:%d after3 ID:%d", count, gl2.ID)
log.Printf("count:%d after3 Lat:%f", count, gl2.Lat)
log.Printf("count:%d after3 Lng:%f", count, gl2.Lng)
}■このクライアント2つ(合計2000オブジェクト)動かしても、落ちなくなった
ようやく一安心
私は、「自分の意志で目指す成功」であるならともかく、「他人の目に映る成功」なんぞの為に、自分が振り回されることなど、ゴメンです。
(Continuation from yesterday)
江端:「まあ、それはさておき、『一旗』って何だ？」
Ebata: "Well, aside from that, what's a 'the flag' ?"
嫁さん:「『故郷に錦を飾る』とも言うね」
Wife: "It's also called 'return to their hometown in glory'"
江端:「『一旗』から想起されるイメージって、ミュージシャン、アイドル、役者、くらいしか思い付かないんだけど」
Ebata: "The only images that 'the flag' reminds me of are musicians, idols and actors"
嫁さん「あるいは、政治家とか野球選手・・・いずれにしても、この程度が私達のイメージが限界かな」
Wife: "Or a politician or a baseball player... Anyway, I guess this is the limit of our image.
江端:「自分の望みのことが達成できれば、それは、『一旗上がった』ということにならないのかな？ 自分なりの目標に対して、それを達成すれば、足るというような」
Ebata: "If they can achieve what they want, is that 'they could raise the flag' ? I suppose it's good enough for my own goals, if I achieve them."
嫁さん「・・・いや、それはちょっと違うかな」
Wife:"...no, that's not enough.
江端:「？」
Ebata:"?"
嫁さん:「『故郷に錦を飾る』と合わせて考えれば、それは、第三者にとって ―― 特に出身地の ―― 多くの人間が、共通して、"成功"と認識できる何かでなければ、成立しない」
Wife: "If they use the phrase of "return to their hometown in glory", the flag should be something that could be perceived as a "success." for many people, especially in their hometown."
江端:「・・・多くの人が共通して価値のあると認められるもの ―― つまり"金"か」
Ebata: "...what most people consider to be of common value -- 'money'"
嫁さん「あるいは、有名になること ―― "名声"も含まれるかな」
Wife: "Or to be famous -- I guess that includes 'fame'"
江端:「第三者から観測可能な"金"と"名声"というとになると ―― ああ、なるほど、『ミュージシャン』などは、分かりやすい」
Ebata: "When it comes to 'money' and 'fame' that can be observed by a third party - ah, I see, 'musicians' is easy to understand.
嫁さん「そうだねえ。そこに至るプロセスが、努力と能力だけでなく、運も必要であり、加えて"その可能性が恐しく小さい"という要件も必要だね」
Wife: "Yes, you're right. The process of getting there requires not only effort and ability, but also luck, and in addition, 'the possibility should be terribly small'.
-----
正直、私は、
Honestly, I thought that
―― 面倒くさいな
"It's troublesome"
と思いました。
私は、「自分の意志で目指す成功」であるならともかく、「他人の目に映る成功」なんぞの為に、自分が振り回されることなど、ゴメンです。
I don't want to be at the mercy of "success in the eyes of others", but "success of my own volition.
-----
最後にいらんことを書き残します。
Finally, I'll leave you with something unnecessary.
こういう、他人視点の"一旗"幻想を持っている方は、このページの一読をお勧めします。
If you have an illusion of the flag in the eyes of others, let you read this article.
文字を読むのが面倒であるなら
If you can't be bothered to read the words, it is O.K. to watch these figures.
参考くらいにはなると思います。
I think it's at least a reference.