1

に文字列を保持するための次の非常に単純なコードがありますdatastore。さまざまな例からまとめましたdatastoreが、まだ満足していません。

その目的は、キーの下に文字列を格納し、下にpersist取得することfromPresistenceです。

// Used to store the string value.
type Entity struct {
    Value string
}

// Grow my key.
func key(x string) *datastore.Key {
    return datastore.NewKey(context, "Persist", x, 0, nil)
}

// Get it from persistence storage.
func fromPersistence(x string) string {
    var persisted string = x
    // Make my key.
    k := key(x)
    // New entity for filling in.
    e := new(Entity)
    // Look it up!
    if err := datastore.Get(context, k, e); err == nil {
        // It was there!
        persisted = e.Value
        context.Debugf("Persisted %s=%s", x, persisted)
    }

    return persisted
}

// Persist the latest number.
func persist(x string) func(*big.Int) {
    return func(n *big.Int) {
        // Make my key.
        k := key(x)
        // New entity for filling in.
        e := new(Entity)
        // Value is the decimal form of the number.
        e.Value = n.String()
        context.Debugf("Persist %s=%s", start, e.Value)
        if _, err := datastore.Put(context, k, e); err != nil {
            context.Debugf("Persist failed! %s", err)
        }
    }
}

しかし、毎回1つずつ遅れているようです。ログの結果は次のとおりです。

C:\Go\GAE\go_appengine\google\src>\go\gae\go_appengine\dev_appserver.py unique/
INFO     2013-10-15 20:55:08,296 sdk_update_checker.py:245] Checking for updates to the SDK.
INFO     2013-10-15 20:55:09,726 api_server.py:138] Starting API server at: http://localhost:50218
INFO     2013-10-15 20:55:09,746 dispatcher.py:168] Starting module "default" running at: http://localhost:8080
INFO     2013-10-15 20:55:09,763 admin_server.py:117] Starting admin server at: http://localhost:8000
INFO     2013-10-15 20:56:22,131 module.py:599] default: "GET / HTTP/1.1" 304 -
INFO     2013-10-15 20:56:22,344 module.py:599] default: "GET /favicon.ico HTTP/1.1" 304 -
INFO     2013-10-15 20:56:22,448 module.py:599] default: "GET /favicon.ico HTTP/1.1" 304 -
2013/10/15 20:56:26 DEBUG: Persisted 38913371956013078496870267859=3378577588146889866220112993
2013/10/15 20:56:26 DEBUG: Persist 38913371956013078496870267859=21186844412818184262771263024
...
2013/10/15 20:56:30 DEBUG: Persist 38913371956013078496870267859=1324177775801136516423203939
INFO     2013-10-15 20:56:30,756 module.py:599] default: "GET /n HTTP/1.1" 200 19
INFO     2013-10-15 20:56:30,927 module.py:599] default: "GET /favicon.ico HTTP/1.1" 304 -
2013/10/15 20:56:32 DEBUG: Persist 38913371956013078496870267859=20778614526287997725322370609

C:\Go\GAE\go_appengine\google\src>\go\gae\go_appengine\dev_appserver.py unique/
INFO     2013-10-15 20:57:15,657 sdk_update_checker.py:245] Checking for updates to the SDK.
INFO     2013-10-15 20:57:17,033 api_server.py:138] Starting API server at: http://localhost:50241
INFO     2013-10-15 20:57:17,085 dispatcher.py:168] Starting module "default" running at: http://localhost:8080
INFO     2013-10-15 20:57:17,098 admin_server.py:117] Starting admin server at: http://localhost:8000
2013/10/15 20:57:24 DEBUG: Persisted 38913371956013078496870267859=1324177775801136516423203939
2013/10/15 20:57:24 DEBUG: Persist 38913371956013078496870267859=20778614526287997725322370609
...

永続化の最後の試行で20778614526287997725322370609が格納されましたが、取得の試行で以前に永続化された値 1324177775801136516423203939 が返されたことがわかります。

私は何を間違っていますか？

注意:コードを変更してcontext.Debugf、デバッグ文字列を出力するメカニズムを使用して、方程式から奇妙なログ レコードを取得しました。

古いLogfコードは次のとおりです。それが奇妙なログエントリの原因だったと確信しています。それは私の質問の対象ではありません。私はこれを自分で修正します。

func Logf(format string, a ...interface{}) {
    if context != nil {
        // Context is valid.
        if len(logQueue) > 0 {
            // Roll out the stored entries.
            for i := 0; i < len(logQueue); i++ {
                context.Debugf("%s", logQueue[i])
            }
            // Empty the queue.
            logQueue = make([]string, 0)
        }
        // Pass a "" to just flush the queue
        if format != "" {
            // Log it through the context.
            context.Debugf(format, a)
        }
    } else {
        // No context! Queue it up.
        logQueue = append(logQueue, fmt.Sprintf(format, a...))
    }

}
4

2 に答える 2

0

ここで、分散システムの予想外の側面の 1 つが見られる可能性は十分にあります。への呼び出しとpersistアプリケーションfromPersistenceの別のインスタンスでの実行が終了した場合、ログ メッセージは保持される場所へのパスがわずかに異なる可能性があります。一見反転したログ メッセージのタイムスタンプは同じであることに注意してください。

于 2013-10-14T01:17:21.823 に答える