すべての問題
async-await - 特定のスレッドで非同期関数を実行する
特定の実行時間の長い関数 (データベース クエリを実行する関数) を別のスレッドで実行したいと考えています。ただし、基盤となるデータベース エンジンでは一度に 1 つの接続しか許可されておらず、接続構造体では許可されていないと仮定しましょうSync(少なくとも後者は に当てはまると思いますdiesel)。
私の解決策は、すべてのデータベース作業が発生し、メインスレッドが生きている限り実行される単一の個別のスレッド (スレッドプールとは対照的に) を持つことです。チャネルを介してメッセージを渡す方法でこれを行う必要があることはわかっていると思いますが、それにはかなりのボイラープレート コードが必要です (たとえば、関数の引数をチャネルを介して明示的に送信するなど)。
このようなことを錆で達成するためのより直接的な方法はありますか?
私は次の行に沿って何かをしたいと思っています:
wherequery_functionは、すぐにフューチャーを返し、他のスレッドで作業を行う関数になります。
Rust nightly と外部クレート/マクロは問題ありません。
amazon-web-services - 呼び出し元による AWS Lambda またはシャードでのコンテナの再利用を防ぐ
AWS Lambda を使用して、ユーザーが任意のコードを実行できるようにしていますが、関連するすべてのリスクがあります。ラムダは調整され、時間制限があるため、私の見解では、コンテナが再利用された場合に将来の呼び出しのために環境が汚染されることが主なリスクです。
関数を再デプロイせずに、呼び出し元が AWS Lambda でコンテナーの再利用を検出、防止、または分割する方法はありますか?
excel - Text_Change イベント VBA を無効にする
親愛なる、
Textbox_change イベントを無効にする方法はありますか?
しかし、それは機能しません。
java - Log4j ファイルが作成されましたが空です
他の質問の回答を試しましたが、問題を解決できませんでした
log4jを構成するためのxmlファイルがあります。2 つのログ ファイルが作成されますが、ファイルは空です。ファイルに書き込めません。
これは私のxmlです
そして、これは初期化クラスです
そして、これが私がログを記録する方法です
しかし、ログ ファイルには何も書き込まれません。エラーが表示されず、他の質問に記載されている解決策を試しました。
node.js - 顧客へのストライプ支払い
私と私のチームは、upworkタイプのオンライン マーケットプレイスを構築しようとしています。BusinessUser がジョブを投稿し、顧客がジョブに入札します。仕事を獲得した後、彼/彼女は仕事を完了します。仕事が完了すれば、彼/彼女は支払われます。stripe決済に利用しています。ストライプを使用して BusinessUser からお金を受け取りました。私たちはすでにその部分を開発しています。仕事が完了したら、顧客は報酬を受け取ります。私の問題は、どうすればこれを行うことができるかということです。
注意: 開発には node.js を使用しています。
typescript2.0 - オブザーバブルから別のオブザーバブルのアイテムの配列に1つのアイテムを追加する方法は?
あるオブザーバブルから同じタイプのアイテムのリストを含む別のオブザーバブルに1つのアイテムを追加したいオブザーバブルとパイプの使用に苦労しています。
私はタイプXを持っています.そしてタイプXIには観察可能な配列があります:
タイプ X のみのオブザーバブルもあります。
このコードはすべて、サービスが X の配列のみを公開するサービス クラスにあります。配列内のデータを非同期パイプで html に表示すると、機能のこの部分が機能します。ホストとクライアントは signalR 手法で接続され、onConnected、タイプ X の項目の配列が取得されます。ただし、アプリケーションが実行されると、バックエンドでタイプ X の新しいアイテムを作成したり、既存のアイテムを変更または削除したりできます。これが発生すると、このアイテムのみが signalR 接続と変更状態を介して送信されます。
フロント エンドでは、このアイテムは既に取得されているタイプ X のアイテムの配列に追加する必要があります。以前に取得したアイテムのリスト?
SignalR が使用されているため、タイプ X の新しいアイテムが作成されたときにクライアントがそれを受け取ると、バックエンドが制御されます。
c# - アプリの分析情報: インストルメンテーション キーを使用してアプリ ID を抽出できません
私の.NETコアプロジェクトでは、アプリの洞察からインストルメンテーションキーを使用してAppIdを抽出しようとしています: TelemetryConfiguration.Active.InstrumentationKey = _configuration["ApplicationInsights:InstrumentationKey"];
ただし、結果は常に false であり、アプリの洞察が存在しないかのように appID は null です。
私が見逃した設定はありますか?誰かが理由を知っていますか?
node.js - dbからの値を使用してnodejsコードの実行から抜け出す方法は?
私は最近phpプログラマーです。プロジェクトを完了するためにnodejsを使用して驚いていますが、残念ながらdynamo dbも使用している可能性があるため、ここで問題が発生しています。それは
実行中のコードはこちら
この後、このコードが機能することを期待しています。
現在、端末でこれを取得していますが、そこで動かなくなり、それ以上の実行はありません。
私が欲しいのは、コードの最初の部分を実行して、クエストの値を出してから、コードの実行を続行することです。どうすればそれを行うことができますか 現在、実行中であり、そこで立ち往生しています vlog.info('Query going fine',JSON.stringify(quest)); これ以上の実行はありません:)
gunicorn - aiohttp と gunicorn: ロガーが機能しない
aiohttp ロガーと gunicorn を使用して、実稼働環境で aiopg 接続設定をデバッグしようとしています。
データベース資格情報をログに記録しようとしています:
models.py:
これは に出力を追加しません/var/log/gunicorn/error_logが、期待されています。
ガンコーンの起動方法は次のとおりです。
aiohttp アプリの作成方法は次のとおりです。
main.py:
android - Android デバイスからホストをトリガーする
Espresso フレームワークを使用して Android テストを実行します。実行中のテストの 1 つの時点で、ホスト PC でオーディオ ファイルの再生をトリガーする必要があります (音声認識をテストするため)。Android、Espresso、adbなどで、Androidデバイスからadb経由で接続されたホストコンピューターにトリガーメッセージを送信できる方法はありますか?
私は何時間もグーグルで検索しましたが、それを行う方法がわかりません。
どんなアイデアにも感謝します。
apache-spark - GCP Dataproc - GCS からの読み取り速度が遅い
ジョブを実行している GCP dataproc クラスタがあります。ジョブの入力は、200 個のパーツ ファイルがあるフォルダーです。各パーツ ファイルのサイズは約 1.2 GB です。
私の仕事は地図操作だけです
プロパティparquet.block.sizeは に設定されて128 MBいます。これは、ジョブ中に各パーツ ファイルが 10 回読み込まれることを意味します。
バケット アクセス ログを有効にして統計を調べたところ、各パーツ ファイルがなんと85 回もアクセスされていることに驚きました。実際のデータを送信するリクエストは 10 個しかないことがわかります。他のリクエストは、0 バイトを返すか、非常に少量を送信しています。
大きな寄木細工のファイルを分割して読み取ることは、Spark の標準的な動作であることは理解しています。また、いくつかのメタデータ交換要求もあるはずですが、8X呼び出しは非常に奇妙なものです。また、転送されたデータの量と所要時間を見ると、データが 100 MB/分の速度で転送されているように見えますが、これは Google の内部データ転送 (GCS から dataproc へ) にとって非常に遅いです。1つのパーツファイルのバイト、所要時間、URLを含むCSVを添付しています。
Dataproc でこのような動作を経験した人はいますか? ファイルへのリクエストが非常に多く、転送速度が遅いことについて説明がありますか。
補足として、バケットと dataproc クラスタの両方が同じリージョンにあります。n1-standard-16 マシンを持つ 50 人のワーカーがいます。
ファイルを添付できなかったので、フォーマットされた内容をここに貼り付けます。


